actfw_core.task package¶
Submodules¶
actfw_core.task.consumer module¶
- class actfw_core.task.consumer.Consumer¶
Bases:
Generic
[actfw_core.task.consumer.T_IN
],actfw_core.task.task.Task
,actfw_core.task.consumer._ConsumerMixin
[actfw_core.task.consumer.T_IN
]Consumer Task.
- proc(i: actfw_core.task.consumer.T_IN) None ¶
Pipeline Task Processor
- Parameters
i – task input
- run() None ¶
Run and start the activity
actfw_core.task.isolated module¶
- class actfw_core.task.isolated.Isolated¶
Bases:
actfw_core.task.task.Task
A task which has no connection.
actfw_core.task.join module¶
- class actfw_core.task.join.Join¶
Bases:
actfw_core.task.task.Task
,actfw_core.task.producer._ProducerMixin
[Tuple
[Any
, …]],actfw_core.task.consumer._ConsumerMixin
[Any
]Join Task.
- run() None ¶
Run and start the activity
actfw_core.task.pipe module¶
- class actfw_core.task.pipe.Pipe¶
Bases:
Generic
[actfw_core.task.pipe.T_OUT
,actfw_core.task.pipe.T_IN
],actfw_core.task.task.Task
,actfw_core.task.producer._ProducerMixin
[actfw_core.task.pipe.T_OUT
],actfw_core.task.consumer._ConsumerMixin
[actfw_core.task.pipe.T_IN
]Straightforward Pipeline Task.
- proc(i: actfw_core.task.pipe.T_IN) actfw_core.task.pipe.T_OUT ¶
Pipeline Task Processor
- run() None ¶
Run and start the activity
actfw_core.task.producer module¶
- class actfw_core.task.producer.Producer¶
Bases:
Generic
[actfw_core.task.producer.T_OUT
],actfw_core.task.task.Task
,actfw_core.task.producer._ProducerMixin
[actfw_core.task.producer.T_OUT
]Producer Task.
- proc() actfw_core.task.producer.T_OUT ¶
Pipeline Task Processor
- run() None ¶
Run and start the activity
actfw_core.task.task module¶
actfw_core.task.tee module¶
- class actfw_core.task.tee.Tee¶
Bases:
Generic
[actfw_core.task.tee.T
],actfw_core.task.task.Task
,actfw_core.task.producer._ProducerMixin
[actfw_core.task.tee.T
],actfw_core.task.consumer._ConsumerMixin
[actfw_core.task.tee.T
]Tee Task.
- run() None ¶
Run and start the activity