[
https://issues.apache.org/jira/browse/AIRFLOW-4231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Raja Saheem Khan updated AIRFLOW-4231:
--------------------------------------
Description:
I am using Airflow with SQL server DB.
* I am trying to manually run a Dag from Airflow screen and from cli using
"airflow trigger_dag <dagid>. In both the cases the Dag run successfully but
never get picked by scheduler.
* If I try to schedule a Dag run then it works fine.
* I did the analysis and found that task_instance table does not get populate
and a result of which the scheduler does not process the dag.
* As I checked the code, I found that line no. 954 of jobs.py does not return
any task. \{code} tis = run.get_task_instances(state=(State.NONE,
State.UP_FOR_RETRY)) \{code}
* When should the task_instance table be populated?
Logs and screen shots are attached for your reference. Could you please look
into the issue and let me know in case more information is required on this.
FYI : @[email protected]
was:
I am using Airflow with SQL server DB.
* I am trying to manually run a Dag from Airflow screen and from cli using
"airflow trigger_dag <dagid>. In both the cases the Dag run successfully but
never get picked by scheduler.
* If I try to schedule a Dag run then it works fine.
* I did the analysis and found that task_instance table does not get populate
and a result of which the scheduler does not process the dag.
* As I checked the code, I found that line no. 954 of jobs.py does not return
any task. \{code} tis = run.get_task_instances(state=(State.NONE,
State.UP_FOR_RETRY)) \{code}
* When should the task_instance table be populated?
Logs and screen shots are attached for your reference. Could you please look
into the issue and let me know in case more information is required on this.
> Airflow Manual trigger not working | when connected to SQL server
> -----------------------------------------------------------------
>
> Key: AIRFLOW-4231
> URL: https://issues.apache.org/jira/browse/AIRFLOW-4231
> Project: Apache Airflow
> Issue Type: Bug
> Components: scheduler
> Affects Versions: 1.10.1
> Reporter: Raja Saheem Khan
> Priority: Major
> Attachments: Aiflow_Dag_Run.jpg, jobs_py.JPG, scheduler_logs.txt
>
>
> I am using Airflow with SQL server DB.
> * I am trying to manually run a Dag from Airflow screen and from cli using
> "airflow trigger_dag <dagid>. In both the cases the Dag run successfully but
> never get picked by scheduler.
> * If I try to schedule a Dag run then it works fine.
> * I did the analysis and found that task_instance table does not get
> populate and a result of which the scheduler does not process the dag.
> * As I checked the code, I found that line no. 954 of jobs.py does not
> return any task. \{code} tis = run.get_task_instances(state=(State.NONE,
> State.UP_FOR_RETRY)) \{code}
> * When should the task_instance table be populated?
> Logs and screen shots are attached for your reference. Could you please look
> into the issue and let me know in case more information is required on this.
> FYI : @[email protected]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
