|View source on GitHub|
A gRPC service server for updating remote job info to MLMD.
tfx.orchestration.portable.execution_watcher.ExecutionWatcher( port: int, address: Optional[str] = None, creds: Optional[grpc.ServerCredentials] = None )
||Which port the service will be using.|
Remote address used to contact the server. Should be formatted as
an ipv4 or ipv6 address in the format
||gRPC server credentials. If left as None, server will use an insecure port.|
||Local network address to the server.|
||Remote network address to the server, same as local_address if not configured.|
||Whether the server has been stopped or not. Stopped servers can not be restarted.|
UpdateExecutionInfo( req, unused_context )
Call back for executor operator to update execution info.
Starts the server.
Stops the server.