Skip to content

Commit

Permalink
test17
Browse files Browse the repository at this point in the history
  • Loading branch information
@lsh0107
lsh0107 committed Jan 6, 2024
1 parent cffc850 commit 0451b7f
Show file tree
Hide file tree
Showing 43 changed files with 1,086 additions and 1 deletion.
146 changes: 146 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 @@ -261,3 +261,24 @@
[2024-01-06T09:29:34.917+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:29:34.917+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:29:34.932+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:29:34.931+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:29:34.940+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld.py took 0.066 seconds
[2024-01-06T09:30:05.705+0000] {processor.py:153} INFO - Started process (PID=3215) to work on /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:30:05.707+0000] {processor.py:743} INFO - Processing file /opt/airflow/dags/HelloWorld.py for tasks to queue
[2024-01-06T09:30:05.708+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:05.708+0000] {dagbag.py:538} INFO - Filling up the DagBag from /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:30:05.726+0000] {processor.py:753} INFO - DAG(s) dict_keys(['HelloWorld']) retrieved from /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:30:05.744+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:05.744+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:30:05.759+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:05.759+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:30:05.767+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld.py took 0.067 seconds
[2024-01-06T09:30:36.405+0000] {processor.py:153} INFO - Started process (PID=3304) to work on /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:30:36.407+0000] {processor.py:743} INFO - Processing file /opt/airflow/dags/HelloWorld.py for tasks to queue
[2024-01-06T09:30:36.408+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:36.408+0000] {dagbag.py:538} INFO - Filling up the DagBag from /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:30:36.427+0000] {processor.py:753} INFO - DAG(s) dict_keys(['HelloWorld']) retrieved from /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:30:36.447+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:36.447+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:30:36.461+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:36.461+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:30:36.470+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld.py took 0.069 seconds
[2024-01-06T09:31:07.056+0000] {processor.py:153} INFO - Started process (PID=3393) to work on /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:31:07.057+0000] {processor.py:743} INFO - Processing file /opt/airflow/dags/HelloWorld.py for tasks to queue
[2024-01-06T09:31:07.057+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:07.057+0000] {dagbag.py:538} INFO - Filling up the DagBag from /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:31:07.066+0000] {processor.py:753} INFO - DAG(s) dict_keys(['HelloWorld']) retrieved from /opt/airflow/dags/HelloWorld.py
[2024-01-06T09:31:07.088+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:07.088+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:31:07.101+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:07.101+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:31:07.112+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld.py took 0.059 seconds
21 changes: 21 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 @@ -268,3 +268,24 @@
[2024-01-06T09:29:50.530+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:29:50.530+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:29:50.542+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:29:50.542+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:29:50.550+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld_v2.py took 0.047 seconds
[2024-01-06T09:30:21.223+0000] {processor.py:153} INFO - Started process (PID=3271) to work on /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:30:21.224+0000] {processor.py:743} INFO - Processing file /opt/airflow/dags/HelloWorld_v2.py for tasks to queue
[2024-01-06T09:30:21.225+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:21.225+0000] {dagbag.py:538} INFO - Filling up the DagBag from /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:30:21.248+0000] {processor.py:753} INFO - DAG(s) dict_keys(['HelloWorld_v2']) retrieved from /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:30:21.270+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:21.270+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:30:21.284+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:21.284+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:30:21.292+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld_v2.py took 0.074 seconds
[2024-01-06T09:30:51.893+0000] {processor.py:153} INFO - Started process (PID=3360) to work on /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:30:51.895+0000] {processor.py:743} INFO - Processing file /opt/airflow/dags/HelloWorld_v2.py for tasks to queue
[2024-01-06T09:30:51.896+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:51.896+0000] {dagbag.py:538} INFO - Filling up the DagBag from /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:30:51.921+0000] {processor.py:753} INFO - DAG(s) dict_keys(['HelloWorld_v2']) retrieved from /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:30:51.939+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:51.939+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:30:51.952+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:51.952+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:30:51.960+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld_v2.py took 0.072 seconds
[2024-01-06T09:31:22.686+0000] {processor.py:153} INFO - Started process (PID=3449) to work on /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:31:22.688+0000] {processor.py:743} INFO - Processing file /opt/airflow/dags/HelloWorld_v2.py for tasks to queue
[2024-01-06T09:31:22.689+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:22.688+0000] {dagbag.py:538} INFO - Filling up the DagBag from /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:31:22.713+0000] {processor.py:753} INFO - DAG(s) dict_keys(['HelloWorld_v2']) retrieved from /opt/airflow/dags/HelloWorld_v2.py
[2024-01-06T09:31:22.731+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:22.730+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:31:22.743+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:22.743+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:31:22.751+0000] {processor.py:175} INFO - Processing /opt/airflow/dags/HelloWorld_v2.py took 0.070 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 @@ -261,3 +261,24 @@
[2024-01-06T09:29:37.166+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:29:37.166+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:29:37.180+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:29:37.180+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:29:37.190+0000] {processor.py:175} INFO - Processing /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py took 0.057 seconds
[2024-01-06T09:30:07.824+0000] {processor.py:153} INFO - Started process (PID=3247) to work on /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py
[2024-01-06T09:30:07.825+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:30:07.825+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:07.825+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:30:07.836+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:30:07.852+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:07.852+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:30:07.864+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:07.864+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:30:07.872+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:30:38.510+0000] {processor.py:153} INFO - Started process (PID=3336) to work on /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py
[2024-01-06T09:30:38.510+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:30:38.511+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:38.511+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:30:38.522+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:30:38.540+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:38.540+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:30:38.553+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:38.553+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:30:38.561+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:31:09.291+0000] {processor.py:153} INFO - Started process (PID=3425) to work on /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_bash_operator.py
[2024-01-06T09:31:09.292+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:31:09.292+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:09.292+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:31:09.303+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:31:09.321+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:09.321+0000] {dag.py:2690} INFO - Sync 1 DAGs
[2024-01-06T09:31:09.332+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:09.332+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:31:09.339+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
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 @@ -343,3 +343,30 @@
[2024-01-06T09:29:36.792+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:29:36.792+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:29:36.793+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:29:36.793+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:29:36.802+0000] {processor.py:175} INFO - Processing /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py took 0.055 seconds
[2024-01-06T09:30:07.503+0000] {processor.py:153} INFO - Started process (PID=3237) to work on /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py
[2024-01-06T09:30:07.503+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:30:07.504+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:07.504+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:30:07.513+0000] {processor.py:753} INFO - DAG(s) dict_keys(['example_branch_datetime_operator_2', 'example_branch_datetime_operator_3', '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:30:07.528+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:07.528+0000] {dag.py:2690} INFO - Sync 3 DAGs
[2024-01-06T09:30:07.541+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:07.541+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:30:07.544+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:07.544+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:30:07.545+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:07.545+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:30:07.552+0000] {processor.py:175} INFO - Processing /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py took 0.051 seconds
[2024-01-06T09:30:38.168+0000] {processor.py:153} INFO - Started process (PID=3326) to work on /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py
[2024-01-06T09:30:38.169+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:30:38.171+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:38.170+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:30:38.181+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:30:38.200+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:38.200+0000] {dag.py:2690} INFO - Sync 3 DAGs
[2024-01-06T09:30:38.215+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:38.215+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:30:38.218+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:38.217+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:30:38.219+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:30:38.219+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:30:38.227+0000] {processor.py:175} INFO - Processing /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py took 0.060 seconds
[2024-01-06T09:31:08.956+0000] {processor.py:153} INFO - Started process (PID=3415) to work on /home/airflow/.local/lib/python3.7/site-packages/airflow/example_dags/example_branch_datetime_operator.py
[2024-01-06T09:31:08.956+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:31:08.956+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:08.956+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:31:08.965+0000] {processor.py:753} INFO - DAG(s) dict_keys(['example_branch_datetime_operator_2', 'example_branch_datetime_operator_3', '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:31:08.980+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:08.980+0000] {dag.py:2690} INFO - Sync 3 DAGs
[2024-01-06T09:31:08.992+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:08.992+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:31:08.994+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:08.994+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:31:08.995+0000] {logging_mixin.py:137} INFO - [2024-01-06T09:31:08.995+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:31:09.003+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
Loading

0 comments on commit 0451b7f

Please sign in to comment.