JobQueue
Bases: Object, IJobQueueHandler
Implementation of local/desktop job request:
language: Language
This property is protected for testing purposes
This codeEntityType is protected.
acknowledge_job(job: AlgorithmNodePacket) -> None
Desktop/Local acknowledge the task processed. Nothing to do.
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
job
|
AlgorithmNodePacket
|
|
required |
get_factory_from_data_queue_handler(
data_queue_handler: str,
) -> IBrokerageFactory
Gets Brokerage Factory for provided IDQH
Parameters:
| Name | Type | Description | Default |
|---|---|---|---|
data_queue_handler
|
str
|
|
required |
Returns:
| Type | Description |
|---|---|
IBrokerageFactory
|
An Instance of Brokerage Factory if possible, otherwise null. |
initialize(
api: IApi, messaging_handler: IMessagingHandler
) -> None
Initialize the job queue:
next_job(
algorithm_path: Optional[str],
) -> Tuple[AlgorithmNodePacket, str]
Desktop/Local Get Next Task - Get task from the Algorithm folder of VS Solution.