Expand description
Spawns new jobs and handles cancellations
The job of the Spawner is to receive either a message indicating to execute a workflow or cancel a job.
It executes each new job in a new Task
allowing for parallelism so multiple jobs can be submitted to the
async executor at once.
Structs§
- Spawner
- The Spawner struct contains the state required to create and cancel jobs
Enums§
- Spawner
Msg - Different types of message that can be received by the Spawner
Functions§
- cancel_
msg - Creates
SpawnerMsg::Cancel
variant from&str
- execute_
msg - Creates
SpawnerMsg::Execute
variant from&str
- spawner_
channel - Create channel required for communication with the Spawner