You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "vatsrahul1001 (via GitHub)" <gi...@apache.org> on 2025/03/03 10:23:20 UTC

[I] Scheduler Crashing || when depends_on_past used in DAG params [airflow]

vatsrahul1001 opened a new issue, #47296:
URL: https://github.com/apache/airflow/issues/47296

   ### Apache Airflow version
   
   3.0.0
   
   ### If "Other Airflow 2 version" selected, which one?
   
   _No response_
   
   ### What happened?
   
   When `depends_on_past` is set as True in the DAG level. Scheduler is crashing.
   
   ### What you think should happen instead?
   
   _No response_
   
   ### How to reproduce
   
   1. Execute a DAG which uses `depends_on_past`= True 
   
   
   ```
   from airflow.utils.task_group import TaskGroup
   from airflow.utils.edgemodifier import Label
   from airflow.models.baseoperator import chain
   from airflow.providers.standard.operators.bash import BashOperator
   from airflow.providers.standard.operators.empty import EmptyOperator
   from airflow.models.dag import DAG
   
   from datetime import datetime, timedelta
   
   two_days = datetime.now() - timedelta(days=2)
   
   default_args = {"owner": "airflow", "depends_on_past": True}
   
   with DAG(
       dag_id="chain_tasks_and_task_groups",
       schedule=None,
       default_args=default_args,
       tags=["core"],
   ) as dag:
       t0 = BashOperator(task_id="sleep_3_seconds", bash_command="sleep 3")
   
       with TaskGroup(group_id="group1") as taskgroup1:
           t1 = EmptyOperator(task_id="dummmy1")
           t2 = EmptyOperator(task_id="dummy2")
           t3 = EmptyOperator(task_id="dummy3")
   
       t7 = BashOperator(task_id="bash_echo", bash_command="echo continue..")
   
       t8 = EmptyOperator(task_id="dummy4")
       t9 = EmptyOperator(task_id="dummy5")
       t10 = EmptyOperator(task_id="dummy6")
       t11 = EmptyOperator(task_id="dummy7")
       t12 = EmptyOperator(task_id="dummy8")
   
   
   # chaining tasks and task groups with labels for regular tasks and grouped tasks
   chain(
       t0,
       [Label("branching to group tasks"), Label("stuff")],
       taskgroup1,
       t7,
       [
           Label("branch one"),
           Label("branch two"),
           Label("branch three"),
           Label("branch four"),
           Label("branch five"),
       ],
       [t8, t9, t10, t11, t12],
   )
   ```
   
   
   ### Operating System
   
   linux
   
   ### Versions of Apache Airflow Providers
   
   _No response_
   
   ### Deployment
   
   Other
   
   ### Deployment details
   
   _No response_
   
   ### Anything else?
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [x] I agree to follow this project's [Code of Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] Scheduler Crashing || when depends_on_past used in DAG params [airflow]

Posted by "ephraimbuddy (via GitHub)" <gi...@apache.org>.
ephraimbuddy closed issue #47296: Scheduler Crashing || when depends_on_past used in DAG params
URL: https://github.com/apache/airflow/issues/47296


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org