Gunicorn APScheduler Sequential Service Channel scheduler
- Python 96.8%
- Shell 3.2%
| .gitignore | ||
| README.md | ||
| requirements.txt | ||
| run | ||
| server.py | ||
Gunicorn APScheduler Sequential Service Channel scheduler
This example shows how to schedule sequential jobs in service channels
$ ./run
22:19:02 Add job channel service_1 job_1
22:19:02 Starting scheduler for channel service_1
22:19:02 Channel service_1 Job job_1 is running (task 1/4)
22:19:02 Channel service_1 Job job_1 is running (task 2/4)
22:19:02 Channel service_1 Job job_1 is running (task 3/4)
22:19:02 Channel service_1 Job job_1 is running (task 4/4)
22:19:03 EVENT_JOB_EXECUTED id: service_1 job_1 1
22:19:03 Cleanup: service_1
22:19:04 Add job channel service_1 job_2
22:19:04 Starting scheduler for channel service_1
22:19:04 Channel service_1 Job job_2 is running (task 1/4)
22:19:04 Channel service_1 Job job_2 is running (task 2/4)
22:19:05 Channel service_1 Job job_2 is running (task 3/4)
22:19:05 Add job channel service_1 job_3
22:19:05 Channel service_1 Job job_2 is running (task 4/4)
22:19:06 EVENT_JOB_EXECUTED id: service_1 job_2 2
22:19:06 Channel service_1 Job job_3 is running (task 1/4)
22:19:06 Channel service_1 Job job_3 is running (task 2/4)
22:19:06 Channel service_1 Job job_3 is running (task 3/4)
22:19:07 Add job channel service_1 job_4
22:19:07 Channel service_1 Job job_3 is running (task 4/4)
22:19:08 EVENT_JOB_EXECUTED id: service_1 job_3 2
22:19:08 Channel service_1 Job job_4 is running (task 1/4)
22:19:08 Channel service_1 Job job_4 is running (task 2/4)
22:19:08 Add job channel service_2 job_1
22:19:08 Starting scheduler for channel service_2
22:19:08 Channel service_2 Job job_1 is running (task 1/4)
22:19:09 Channel service_1 Job job_4 is running (task 3/4)
22:19:09 Channel service_2 Job job_1 is running (task 2/4)
22:19:09 Channel service_1 Job job_4 is running (task 4/4)
22:19:10 Channel service_2 Job job_1 is running (task 3/4)
22:19:10 Add job channel service_2 job_2
22:19:10 EVENT_JOB_EXECUTED id: service_1 job_4 1
22:19:10 Cleanup: service_1
22:19:10 Channel service_2 Job job_1 is running (task 4/4)
22:19:11 EVENT_JOB_EXECUTED id: service_2 job_1 2
22:19:11 Channel service_2 Job job_2 is running (task 1/4)
22:19:12 Channel service_2 Job job_2 is running (task 2/4)
22:19:12 Add job channel service_2 job_3
22:19:13 Channel service_2 Job job_2 is running (task 3/4)
22:19:13 Channel service_2 Job job_2 is running (task 4/4)
22:19:14 Add job channel service_2 job_4
22:19:14 EVENT_JOB_EXECUTED id: service_2 job_2 3
22:19:14 Channel service_2 Job job_3 is running (task 1/4)
22:19:15 Channel service_2 Job job_3 is running (task 2/4)
22:19:15 Channel service_2 Job job_3 is running (task 3/4)
22:19:15 Add job channel service_3 job_1
22:19:15 Starting scheduler for channel service_3
22:19:15 Channel service_3 Job job_1 is running (task 1/4)
22:19:16 Channel service_3 Job job_1 is running (task 2/4)
22:19:16 Channel service_2 Job job_3 is running (task 4/4)
22:19:16 EVENT_JOB_EXECUTED id: service_2 job_3 2
22:19:16 Channel service_2 Job job_4 is running (task 1/4)
22:19:17 Channel service_3 Job job_1 is running (task 3/4)
22:19:17 Channel service_3 Job job_1 is running (task 4/4)
22:19:17 Add job channel service_3 job_2
22:19:17 Channel service_2 Job job_4 is running (task 2/4)
22:19:17 EVENT_JOB_EXECUTED id: service_3 job_1 2
22:19:17 Channel service_3 Job job_2 is running (task 1/4)
22:19:17 Channel service_3 Job job_2 is running (task 2/4)
22:19:17 Channel service_3 Job job_2 is running (task 3/4)
22:19:18 Channel service_3 Job job_2 is running (task 4/4)
22:19:18 Channel service_2 Job job_4 is running (task 3/4)
22:19:18 EVENT_JOB_EXECUTED id: service_3 job_2 1
22:19:18 Cleanup: service_3
22:19:19 Channel service_2 Job job_4 is running (task 4/4)
22:19:19 Add job channel service_3 job_3
22:19:19 Starting scheduler for channel service_3
22:19:19 Channel service_3 Job job_3 is running (task 1/4)
22:19:19 Channel service_3 Job job_3 is running (task 2/4)
22:19:19 Channel service_3 Job job_3 is running (task 3/4)
22:19:19 Channel service_3 Job job_3 is running (task 4/4)
22:19:19 EVENT_JOB_EXECUTED id: service_2 job_4 1
22:19:19 Cleanup: service_2
22:19:19 EVENT_JOB_EXECUTED id: service_3 job_3 1
22:19:19 Cleanup: service_3
22:19:20 Add job channel service_3 job_4
22:19:20 Starting scheduler for channel service_3
22:19:20 Channel service_3 Job job_4 is running (task 1/4)
22:19:21 Channel service_3 Job job_4 is running (task 2/4)
22:19:22 Add job channel service_4 job_1
22:19:22 Starting scheduler for channel service_4
22:19:22 Channel service_4 Job job_1 is running (task 1/4)
22:19:22 Channel service_3 Job job_4 is running (task 3/4)
22:19:22 Channel service_4 Job job_1 is running (task 2/4)
22:19:23 Channel service_3 Job job_4 is running (task 4/4)
22:19:23 Channel service_4 Job job_1 is running (task 3/4)
22:19:23 Add job channel service_4 job_2
22:19:23 EVENT_JOB_EXECUTED id: service_3 job_4 1
22:19:23 Cleanup: service_3
22:19:23 Channel service_4 Job job_1 is running (task 4/4)
22:19:24 EVENT_JOB_EXECUTED id: service_4 job_1 2
22:19:24 Channel service_4 Job job_2 is running (task 1/4)
22:19:24 Channel service_4 Job job_2 is running (task 2/4)
22:19:24 Channel service_4 Job job_2 is running (task 3/4)
22:19:24 Channel service_4 Job job_2 is running (task 4/4)
22:19:24 EVENT_JOB_EXECUTED id: service_4 job_2 1
22:19:24 Cleanup: service_4
22:19:24 Add job channel service_4 job_3
22:19:24 Starting scheduler for channel service_4
22:19:24 Channel service_4 Job job_3 is running (task 1/4)
22:19:25 Channel service_4 Job job_3 is running (task 2/4)
22:19:25 Channel service_4 Job job_3 is running (task 3/4)
22:19:26 Channel service_4 Job job_3 is running (task 4/4)
22:19:26 Add job channel service_4 job_4
22:19:27 EVENT_JOB_EXECUTED id: service_4 job_3 2
22:19:27 Channel service_4 Job job_4 is running (task 1/4)
22:19:27 Channel service_4 Job job_4 is running (task 2/4)
22:19:28 Channel service_4 Job job_4 is running (task 3/4)
22:19:28 Channel service_4 Job job_4 is running (task 4/4)
22:19:29 EVENT_JOB_EXECUTED id: service_4 job_4 1
22:19:29 Cleanup: service_4