@Dagster Jarred
The issue is that I have a pipeline which works perfectly with crons. (I have a @schedule which queries the database for a config and yields multiple jobs)
Now I want to migrate to using celery and rabbit MQ because the crons are not scalable.
Unfortunately I was not able to find an example to help me in this.