Skip to content

Instantly share code, notes, and snippets.

@criccomini
Created January 23, 2017 20:25
Show Gist options
  • Save criccomini/a2b2762763c8ba65fefcdd669e8ffd65 to your computer and use it in GitHub Desktop.
Save criccomini/a2b2762763c8ba65fefcdd669e8ffd65 to your computer and use it in GitHub Desktop.
airflow scheduler log
[2017-01-23 20:17:46,475] {jobs.py:1140} DagFileProcessor36 INFO - Processing dag1
[2017-01-23 20:17:46,737] {jobs.py:1144} DagFileProcessor36 INFO - Created <DagRun dag1 @ 2017-01-23 18:32:00: scheduled__2017-01-23T18:32:00, externally triggered: False>
[2017-01-23 20:17:46,741] {jobs.py:821} DagFileProcessor36 INFO - Examining DAG run <DagRun dag1 @ 2017-01-23 16:47:00: scheduled__2017-01-23T16:47:00, externally triggered: False>
[2017-01-23 20:17:46,918] {models.py:3950} DagFileProcessor36 INFO - Updating state for <DagRun dag1 @ 2017-01-23 16:47:00: scheduled__2017-01-23T16:47:00, externally triggered: False> considering 2 task(s)
[2017-01-23 20:17:46,934] {jobs.py:821} DagFileProcessor36 INFO - Examining DAG run <DagRun dag1 @ 2017-01-23 17:02:00: scheduled__2017-01-23T17:02:00, externally triggered: False>
[2017-01-23 20:17:47,114] {models.py:3950} DagFileProcessor36 INFO - Updating state for <DagRun dag1 @ 2017-01-23 17:02:00: scheduled__2017-01-23T17:02:00, externally triggered: False> considering 2 task(s)
[2017-01-23 20:17:47,142] {jobs.py:821} DagFileProcessor36 INFO - Examining DAG run <DagRun dag1 @ 2017-01-23 18:17:00: scheduled__2017-01-23T18:17:00, externally triggered: False>
[2017-01-23 20:17:47,307] {models.py:3950} DagFileProcessor36 INFO - Updating state for <DagRun dag1 @ 2017-01-23 18:17:00: scheduled__2017-01-23T18:17:00, externally triggered: False> considering 2 task(s)
[2017-01-23 20:17:47,335] {jobs.py:821} DagFileProcessor36 INFO - Examining DAG run <DagRun dag1 @ 2017-01-23 18:32:00: scheduled__2017-01-23T18:32:00, externally triggered: False>
[2017-01-23 20:17:47,498] {models.py:3950} DagFileProcessor36 INFO - Updating state for <DagRun dag1 @ 2017-01-23 18:32:00: scheduled__2017-01-23T18:32:00, externally triggered: False> considering 2 task(s)
[2017-01-23 20:17:59,700] {jobs.py:1140} DagFileProcessor36 INFO - Processing dag2
[2017-01-23 20:17:59,787] {jobs.py:1140} DagFileProcessor36 INFO - Processing dag3
[2017-01-23 20:17:59,812] {jobs.py:821} DagFileProcessor36 INFO - Examining DAG run <DagRun dag3 @ 2017-01-21 04:00:00: scheduled__2017-01-21T04:00:00, externally triggered: False>
[2017-01-23 20:17:59,833] {models.py:3950} DagFileProcessor36 INFO - Updating state for <DagRun dag3 @ 2017-01-21 04:00:00: scheduled__2017-01-21T04:00:00, externally triggered: False> considering 2 task(s)
[2017-01-23 20:17:59,893] {jobs.py:1140} DagFileProcessor36 INFO - Processing dag4
[2017-01-23 20:18:00,325] {jobs.py:1144} DagFileProcessor36 INFO - Created <DagRun dag4 @ 2017-01-23 18:32:00: scheduled__2017-01-23T18:32:00, externally triggered: False>
[2017-01-23 20:18:00,337] {jobs.py:821} DagFileProcessor36 INFO - Examining DAG run <DagRun dag4 @ 2017-01-23 18:17:00: scheduled__2017-01-23T18:17:00, externally triggered: False>
[2017-01-23 20:18:00,605] {models.py:3950} DagFileProcessor36 INFO - Updating state for <DagRun dag4 @ 2017-01-23 18:17:00: scheduled__2017-01-23T18:17:00, externally triggered: False> considering 2 task(s)
[2017-01-23 20:18:00,628] {jobs.py:821} DagFileProcessor36 INFO - Examining DAG run <DagRun dag4 @ 2017-01-23 18:32:00: scheduled__2017-01-23T18:32:00, externally triggered: False>
[2017-01-23 20:18:00,913] {models.py:3950} DagFileProcessor36 INFO - Updating state for <DagRun dag4 @ 2017-01-23 18:32:00: scheduled__2017-01-23T18:32:00, externally triggered: False> considering 2 task(s)
[2017-01-23 20:18:16,330] {jobs.py:1140} DagFileProcessor36 INFO - Processing dag5
[2017-01-23 20:18:16,679] {jobs.py:1144} DagFileProcessor36 INFO - Created <DagRun dag5 @ 2017-01-22 12:15:00: scheduled__2017-01-22T12:15:00, externally triggered: False>
[2017-01-23 20:18:16,684] {jobs.py:821} DagFileProcessor36 INFO - Examining DAG run <DagRun dag5 @ 2017-01-22 12:15:00: scheduled__2017-01-22T12:15:00, externally triggered: False>
[2017-01-23 20:18:16,819] {models.py:3950} DagFileProcessor36 INFO - Updating state for <DagRun dag5 @ 2017-01-22 12:15:00: scheduled__2017-01-22T12:15:00, externally triggered: False> considering 2 task(s)
[2017-01-23 20:18:30,998] {jobs.py:1140} DagFileProcessor36 INFO - Processing dag6
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment