Skip to content

Commit 31d70e7

Browse files
dev-vivekkumarvermadev-vivekkumarverma
committed
added the workflow, dags, tasks and operators
1 parent b40ed77 commit 31d70e7

File tree

65 files changed

+33857
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

65 files changed

+33857
-0
lines changed

‎.gitignore

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,3 +4,6 @@
44

55
# ignore the virtual env
66
*venv/*
7+
8+
# ignore all the logs of airflow
9+
logs*

‎README.md

Lines changed: 24 additions & 0 deletions

‎airflow.db

20 KB
Binary file not shown.

‎img_src/DagtaskoperatorInternal.png

195 KB

‎img_src/task and operators.png

138 KB

‎img_src/task life Cycle.png

324 KB

‎img_src/workflow.png

201 KB

‎logs/dag_processor_manager/dag_processor_manager.log

Lines changed: 7452 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_bash_decorator.py.log

Lines changed: 329 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_bash_operator.py.log

Lines changed: 322 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_branch_datetime_operator.py.log

Lines changed: 423 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_branch_day_of_week_operator.py.log

Lines changed: 329 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_branch_labels.py.log

Lines changed: 343 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_branch_operator.py.log

Lines changed: 322 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_branch_operator_decorator.py.log

Lines changed: 343 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_branch_python_dop_operator_3.py.log

Lines changed: 322 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_complex.py.log

Lines changed: 322 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_dag_decorator.py.log

Lines changed: 420 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_dataset_alias.py.log

Lines changed: 660 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_dataset_alias_with_no_taskflow.py.log

Lines changed: 660 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_datasets.py.log

Lines changed: 1008 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_display_name.py.log

Lines changed: 434 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_dynamic_task_mapping.py.log

Lines changed: 385 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_dynamic_task_mapping_with_no_taskflow_operators.py.log

Lines changed: 406 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_external_task_marker_dag.py.log

Lines changed: 448 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_inlet_event_extra.py.log

Lines changed: 408 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_kubernetes_executor.py.log

Lines changed: 378 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_latest_only.py.log

Lines changed: 371 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_latest_only_with_trigger.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_local_kubernetes_executor.py.log

Lines changed: 737 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_nested_branch_dag.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_outlet_event_extra.py.log

Lines changed: 603 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_params_trigger_ui.py.log

Lines changed: 462 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_params_ui_tutorial.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_passing_params_via_test_command.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_python_decorator.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_python_operator.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_sensor_decorator.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_sensors.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_setup_teardown.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_setup_teardown_taskflow.py.log

Lines changed: 483 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_short_circuit_decorator.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_short_circuit_operator.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_skip_dag.py.log

Lines changed: 483 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_sla_dag.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_subdag_operator.py.log

Lines changed: 828 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_task_group.py.log

Lines changed: 476 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_task_group_decorator.py.log

Lines changed: 476 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_time_delta_sensor_async.py.log

Lines changed: 469 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_trigger_controller_dag.py.log

Lines changed: 476 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_trigger_target_dag.py.log

Lines changed: 483 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_workday_timetable.py.log

Lines changed: 483 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_xcom.py.log

Lines changed: 483 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/example_xcomargs.py.log

Lines changed: 552 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/plugins/decreasing_priority_weight_strategy.py.log

Lines changed: 345 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/plugins/event_listener.py.log

Lines changed: 345 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/plugins/listener_plugin.py.log

Lines changed: 345 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/plugins/workday.py.log

Lines changed: 345 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/subdags/subdag.py.log

Lines changed: 345 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/tutorial.py.log

Lines changed: 483 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/tutorial_dag.py.log

Lines changed: 483 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/tutorial_objectstorage.py.log

Lines changed: 483 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/tutorial_taskflow_api.py.log

Lines changed: 483 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/tutorial_taskflow_api_virtualenv.py.log

Lines changed: 483 additions & 0 deletions
Large diffs are not rendered by default.

‎logs/scheduler/2025-01-28/native_dags/example_dags/tutorial_taskflow_templates.py.log

Lines changed: 483 additions & 0 deletions
Large diffs are not rendered by default.

0 commit comments

Comments
 (0)