From 13d9beb52cdf97481e5b90e6d0767245c7d84332 Mon Sep 17 00:00:00 2001 From: bernarto4ecap Date: Thu, 16 Dec 2021 15:53:49 +0800 Subject: [PATCH] * project/bldb/src/main/java/com/fe/client/SchedulerMgmt.java Added: for the new cpython engine --- project/bldb/src/main/java/com/fe/client/SchedulerMgmt.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/project/bldb/src/main/java/com/fe/client/SchedulerMgmt.java b/project/bldb/src/main/java/com/fe/client/SchedulerMgmt.java index 6a6c5dc..49ab4d9 100644 --- a/project/bldb/src/main/java/com/fe/client/SchedulerMgmt.java +++ b/project/bldb/src/main/java/com/fe/client/SchedulerMgmt.java @@ -84,6 +84,7 @@ import com.fourelementscapital.scheduler.error.ClientError; import com.fourelementscapital.scheduler.group.DirectRServeExecuteRUnix; import com.fourelementscapital.scheduler.group.REngineScriptTask; import com.fourelementscapital.scheduler.group.RServeUnixTask; +import com.fourelementscapital.scheduler.group.PythonScriptTask; import com.fourelementscapital.scheduler.p2p.P2PService; import com.fourelementscapital.scheduler.p2p.listener.IncomingMessage; import com.fourelementscapital.scheduler.p2p.listener.P2PTransportMessage; @@ -2716,6 +2717,11 @@ public class SchedulerMgmt extends AbstractTeamOrgMgmt { rserve_p.add(RServeUnixTask.ENGINE_NAME); rserve_p.add(RServeUnixTask.ENGINE_EXECUTER_UNIX_NAME); // rtn.put("rserve_unix_peers", sdb.getPeersList4Engine(rserve_p)); + + ArrayList python_p = new ArrayList(); + python_p.add( PythonScriptTask.ENGINE_NAME ); + rtn.put("python_peers", sdb.getPeersList4Engine(python_p)); + rtn.put("peernotes", sdb.getPeersData()); int last10sec=10000;