View Source PipelineRunServer.Worker (Datapio OpenCore v0.1.0)

Consume PipelineRunRequest from queues.

Link to this section Summary

Functions

Return a specification to run the consumer under a supervisor

Shutdown the consumer

Start a consumer linked to the current process

Link to this section Functions

Specs

Return a specification to run the consumer under a supervisor

Specs

shutdown(Datapio.MQ.Consumer.consumer_id()) :: :ok

Shutdown the consumer

Specs

Start a consumer linked to the current process