调用方submit_job
调用
job_app.py
响应完毕
federated_api()
Python
否
stub.unaryCall()
unaryCall()
client.unaryCall()
Proxy.java
DataTransferPipedClient.java
注册服务功能
DataTransferServiceImpl.java
UnaryCall()|▼publishEvent()
OnComplete()
Java客户端
为空
createServer(configPath)
submit_job()
call_fun()
得到响应
Python请求unaryCall
CascadedCaller.java
发布事件
fate_flow_server.py
proxy_pb2_grpc.add_DataTransferServiceServicer_to_server()
grpc_utils.py
unaryCall()| ▼ getStub()
remote_api()
job_controller.py
集群
TaskScheduler.distribute_job()
创建
wrap_grpc_packet（）
Python客户端
循环判断响应时间是否超时
判断工作模式
Java请求unaryCall
PipHandleNotificationEventListener.java
fate_flow_client.py
Java服务端
监听事件结束
onApplicationEvent|▼cascadedCaller.run
Python服务端
取出Packet判空
Java
ClientUnaryCallResponseStreamObserver.java
api_util.py
