IJobQueueHandler
Task requestor interface with cloud system
acknowledge_job(job: AlgorithmNodePacket) -> None
Signal task complete
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
job
|
AlgorithmNodePacket
|
Work to do. |
required |
initialize(
api: IApi, messaging_handler: IMessagingHandler
) -> None
Initialize the internal state
next_job(
algorithm_path: Optional[str],
) -> Tuple[AlgorithmNodePacket, str]
Request the next task to run through the engine:
Returns:
| Type | Description |
|---|---|
Tuple[AlgorithmNodePacket, str]
|
Algorithm job to process. |