Skip to content

Commit

Permalink
test20
Browse files Browse the repository at this point in the history
  • Loading branch information
@lsh0107
lsh0107 committed Jan 6, 2024
1 parent 5c72b7f commit f1b57c2
Show file tree
Hide file tree
Showing 43 changed files with 1,077 additions and 1 deletion.
144 changes: 144 additions & 0 deletions logs/dag_processor_manager/dag_processor_manager.log
View file

Large diffs are not rendered by default.

21 changes: 21 additions & 0 deletions logs/scheduler/2024-01-06/HelloWorld.py.log
View file
Original file line number Diff line number Diff line change
Expand Up @@ -422,3 +422,24 @@
[2024-01-06T09:41:21.023+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:21.023+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:41:21.038+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:21.037+0000] {dag.py:3441} INFO - Setting next_dagrun for HelloWorld to 2024-01-05T02:00:00+00:00, run_after=2024-01-06T02:00:00+00:00
[2024-01-06T09:41:21.046+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld.py took 0.068 seconds
[2024-01-06T09:41:51.863+0000] {processor.py:153} INFO - Started process (PID=5164) to work on /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:41:51.864+0000] {processor.py:743} INFO - Processing file /opt/airflow/dags/HelloWorld.py for tasks to queue
[2024-01-06T09:41:51.865+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:51.865+0000] {dagbag.py:538} INFO - Filling up the DagBag from /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:41:51.880+0000] {processor.py:753} INFO - DAG(s) dict_keys(['HelloWorld']) retrieved from /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:41:51.906+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:51.906+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:41:51.923+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:51.923+0000] {dag.py:3441} INFO - Setting next_dagrun for HelloWorld to 2024-01-05T02:00:00+00:00, run_after=2024-01-06T02:00:00+00:00
[2024-01-06T09:41:51.932+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld.py took 0.076 seconds
[2024-01-06T09:42:22.570+0000] {processor.py:153} INFO - Started process (PID=5253) to work on /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:42:22.572+0000] {processor.py:743} INFO - Processing file /opt/airflow/dags/HelloWorld.py for tasks to queue
[2024-01-06T09:42:22.573+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:22.573+0000] {dagbag.py:538} INFO - Filling up the DagBag from /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:42:22.591+0000] {processor.py:753} INFO - DAG(s) dict_keys(['HelloWorld']) retrieved from /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:42:22.609+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:22.609+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:42:22.623+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:22.623+0000] {dag.py:3441} INFO - Setting next_dagrun for HelloWorld to 2024-01-05T02:00:00+00:00, run_after=2024-01-06T02:00:00+00:00
[2024-01-06T09:42:22.632+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld.py took 0.068 seconds
[2024-01-06T09:42:53.270+0000] {processor.py:153} INFO - Started process (PID=5341) to work on /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:42:53.272+0000] {processor.py:743} INFO - Processing file /opt/airflow/dags/HelloWorld.py for tasks to queue
[2024-01-06T09:42:53.273+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:53.273+0000] {dagbag.py:538} INFO - Filling up the DagBag from /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:42:53.290+0000] {processor.py:753} INFO - DAG(s) dict_keys(['HelloWorld']) retrieved from /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:42:53.308+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:53.308+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:42:53.322+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:53.322+0000] {dag.py:3441} INFO - Setting next_dagrun for HelloWorld to 2024-01-05T02:00:00+00:00, run_after=2024-01-06T02:00:00+00:00
[2024-01-06T09:42:53.331+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld.py took 0.067 seconds
14 changes: 14 additions & 0 deletions logs/scheduler/2024-01-06/HelloWorld_v2.py.log
View file
Original file line number Diff line number Diff line change
Expand Up @@ -429,3 +429,17 @@
[2024-01-06T09:41:36.672+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:36.672+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:41:36.686+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:36.685+0000] {dag.py:3441} INFO - Setting next_dagrun for HelloWorld_v2 to 2024-01-05T02:00:00+00:00, run_after=2024-01-06T02:00:00+00:00
[2024-01-06T09:41:36.694+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld_v2.py took 0.067 seconds
[2024-01-06T09:42:07.366+0000] {processor.py:153} INFO - Started process (PID=5236) to work on /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:42:07.366+0000] {processor.py:743} INFO - Processing file /opt/airflow/dags/HelloWorld_v2.py for tasks to queue
[2024-01-06T09:42:07.367+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:07.367+0000] {dagbag.py:538} INFO - Filling up the DagBag from /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:42:07.380+0000] {processor.py:753} INFO - DAG(s) dict_keys(['HelloWorld_v2']) retrieved from /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:42:07.398+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:07.398+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:42:07.414+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:07.414+0000] {dag.py:3441} INFO - Setting next_dagrun for HelloWorld_v2 to 2024-01-05T02:00:00+00:00, run_after=2024-01-06T02:00:00+00:00
[2024-01-06T09:42:07.423+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld_v2.py took 0.060 seconds
[2024-01-06T09:42:38.087+0000] {processor.py:153} INFO - Started process (PID=5309) to work on /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:42:38.088+0000] {processor.py:743} INFO - Processing file /opt/airflow/dags/HelloWorld_v2.py for tasks to queue
[2024-01-06T09:42:38.089+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:38.089+0000] {dagbag.py:538} INFO - Filling up the DagBag from /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:42:38.113+0000] {processor.py:753} INFO - DAG(s) dict_keys(['HelloWorld_v2']) retrieved from /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:42:38.131+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:38.131+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:42:38.144+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:38.144+0000] {dag.py:3441} INFO - Setting next_dagrun for HelloWorld_v2 to 2024-01-05T02:00:00+00:00, run_after=2024-01-06T02:00:00+00:00
[2024-01-06T09:42:38.153+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld_v2.py took 0.071 seconds
21 changes: 21 additions & 0 deletions logs/scheduler/2024-01-06/native_dags/example_dags/example_bash_operator.py.log
View file
Original file line number Diff line number Diff line change
Expand Up @@ -422,3 +422,24 @@
[2024-01-06T09:41:23.246+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:23.246+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:41:23.259+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:23.258+0000] {dag.py:3441} INFO - Setting next_dagrun for example_bash_operator to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:41:23.267+0000] {processor.py:175} INFO - Processing /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py took 0.053 seconds
[2024-01-06T09:41:54.015+0000] {processor.py:153} INFO - Started process (PID=5196) to work on /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py
[2024-01-06T09:41:54.015+0000] {processor.py:743} INFO - Processing file /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py for tasks to queue
[2024-01-06T09:41:54.016+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:54.016+0000] {dagbag.py:538} INFO - Filling up the DagBag from /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py
[2024-01-06T09:41:54.027+0000] {processor.py:753} INFO - DAG(s) dict_keys(['example_bash_operator']) retrieved from /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py
[2024-01-06T09:41:54.045+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:54.044+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:41:54.056+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:54.056+0000] {dag.py:3441} INFO - Setting next_dagrun for example_bash_operator to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:41:54.063+0000] {processor.py:175} INFO - Processing /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py took 0.050 seconds
[2024-01-06T09:42:24.721+0000] {processor.py:153} INFO - Started process (PID=5285) to work on /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py
[2024-01-06T09:42:24.721+0000] {processor.py:743} INFO - Processing file /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py for tasks to queue
[2024-01-06T09:42:24.722+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:24.722+0000] {dagbag.py:538} INFO - Filling up the DagBag from /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py
[2024-01-06T09:42:24.733+0000] {processor.py:753} INFO - DAG(s) dict_keys(['example_bash_operator']) retrieved from /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py
[2024-01-06T09:42:24.750+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:24.750+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:42:24.761+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:24.761+0000] {dag.py:3441} INFO - Setting next_dagrun for example_bash_operator to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:42:24.769+0000] {processor.py:175} INFO - Processing /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py took 0.050 seconds
[2024-01-06T09:42:55.334+0000] {processor.py:153} INFO - Started process (PID=5373) to work on /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py
[2024-01-06T09:42:55.334+0000] {processor.py:743} INFO - Processing file /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py for tasks to queue
[2024-01-06T09:42:55.335+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:55.334+0000] {dagbag.py:538} INFO - Filling up the DagBag from /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py
[2024-01-06T09:42:55.346+0000] {processor.py:753} INFO - DAG(s) dict_keys(['example_bash_operator']) retrieved from /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py
[2024-01-06T09:42:55.363+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:55.363+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:42:55.376+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:55.376+0000] {dag.py:3441} INFO - Setting next_dagrun for example_bash_operator to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:42:55.383+0000] {processor.py:175} INFO - Processing /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py took 0.052 seconds
27 changes: 27 additions & 0 deletions logs/scheduler/2024-01-06/native_dags/example_dags/example_branch_datetime_operator.py.log
View file
Original file line number Diff line number Diff line change
Expand Up @@ -550,3 +550,30 @@
[2024-01-06T09:41:22.846+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:22.846+0000] {dag.py:3441} INFO - Setting next_dagrun for example_branch_datetime_operator_2 to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:41:22.847+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:22.847+0000] {dag.py:3441} INFO - Setting next_dagrun for example_branch_datetime_operator_3 to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:41:22.856+0000] {processor.py:175} INFO - Processing /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py took 0.069 seconds
[2024-01-06T09:41:53.669+0000] {processor.py:153} INFO - Started process (PID=5186) to work on /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py
[2024-01-06T09:41:53.669+0000] {processor.py:743} INFO - Processing file /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py for tasks to queue
[2024-01-06T09:41:53.669+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:53.669+0000] {dagbag.py:538} INFO - Filling up the DagBag from /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py
[2024-01-06T09:41:53.678+0000] {processor.py:753} INFO - DAG(s) dict_keys(['example_branch_datetime_operator_3', 'example_branch_datetime_operator_2', 'example_branch_datetime_operator']) retrieved from /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py
[2024-01-06T09:41:53.694+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:53.693+0000] {dag.py:2690} INFO - Sync 3 DAGs
[2024-01-06T09:41:53.705+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:53.705+0000] {dag.py:3441} INFO - Setting next_dagrun for example_branch_datetime_operator to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:41:53.707+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:53.707+0000] {dag.py:3441} INFO - Setting next_dagrun for example_branch_datetime_operator_2 to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:41:53.708+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:41:53.708+0000] {dag.py:3441} INFO - Setting next_dagrun for example_branch_datetime_operator_3 to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:41:53.715+0000] {processor.py:175} INFO - Processing /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py took 0.049 seconds
[2024-01-06T09:42:24.392+0000] {processor.py:153} INFO - Started process (PID=5275) to work on /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py
[2024-01-06T09:42:24.392+0000] {processor.py:743} INFO - Processing file /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py for tasks to queue
[2024-01-06T09:42:24.393+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:24.393+0000] {dagbag.py:538} INFO - Filling up the DagBag from /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py
[2024-01-06T09:42:24.401+0000] {processor.py:753} INFO - DAG(s) dict_keys(['example_branch_datetime_operator', 'example_branch_datetime_operator_3', 'example_branch_datetime_operator_2']) retrieved from /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py
[2024-01-06T09:42:24.416+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:24.416+0000] {dag.py:2690} INFO - Sync 3 DAGs
[2024-01-06T09:42:24.428+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:24.428+0000] {dag.py:3441} INFO - Setting next_dagrun for example_branch_datetime_operator to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:42:24.430+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:24.429+0000] {dag.py:3441} INFO - Setting next_dagrun for example_branch_datetime_operator_2 to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:42:24.431+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:24.431+0000] {dag.py:3441} INFO - Setting next_dagrun for example_branch_datetime_operator_3 to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:42:24.437+0000] {processor.py:175} INFO - Processing /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py took 0.048 seconds
[2024-01-06T09:42:55.027+0000] {processor.py:153} INFO - Started process (PID=5363) to work on /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py
[2024-01-06T09:42:55.027+0000] {processor.py:743} INFO - Processing file /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py for tasks to queue
[2024-01-06T09:42:55.027+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:55.027+0000] {dagbag.py:538} INFO - Filling up the DagBag from /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py
[2024-01-06T09:42:55.036+0000] {processor.py:753} INFO - DAG(s) dict_keys(['example_branch_datetime_operator_3', 'example_branch_datetime_operator_2', 'example_branch_datetime_operator']) retrieved from /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py
[2024-01-06T09:42:55.051+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:55.051+0000] {dag.py:2690} INFO - Sync 3 DAGs
[2024-01-06T09:42:55.063+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:55.063+0000] {dag.py:3441} INFO - Setting next_dagrun for example_branch_datetime_operator to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:42:55.066+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:55.066+0000] {dag.py:3441} INFO - Setting next_dagrun for example_branch_datetime_operator_2 to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:42:55.069+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:42:55.069+0000] {dag.py:3441} INFO - Setting next_dagrun for example_branch_datetime_operator_3 to 2024-01-05T00:00:00+00:00, run_after=2024-01-06T00:00:00+00:00
[2024-01-06T09:42:55.077+0000] {processor.py:175} INFO - Processing /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py took 0.052 seconds
Loading

0 comments on commit f1b57c2

Please sign in to comment.