Unable to run the DAG through UI

[Chowduri Manjunatha]

Hi ,

Tried re running the task through GUI and getting the below error.

Please check the highlighted line " /home/ec2-user/airflow/dag_test//home/ec2-user/airflow/dag_test/Test_dag2.py" actual directory is  "/home/ec2-user/airflow/dag_test/Test_dag2.py".

Can someone guide me to resolve the issue.

[2016-03-16 08:48:34,807] {__init__.py:36} INFO - Using executor CeleryExecutor

Traceback (most recent call last):

  File "/usr/local/bin/airflow", line 15, in <module>

    args.func(args)

  File "/usr/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 134, in run

    raise AirflowException(msg)

airflow.utils.AirflowException: DAG [First_P2] could not be found in /home/ec2-user/airflow/dag_test//home/ec2-user/airflow/dag_test/Test_dag2.py

[2016-03-16 08:48:35,391: ERROR/Worker-4] 1

[2016-03-16 08:48:35,511: ERROR/MainProcess] Task airflow.executors.celery_executor.execute_command[04f47629-e5ab-4c2d-b9ff-75be215c9382] raised unexpected: AirflowException('Celery command failed',)

Traceback (most recent call last):

  File "/usr/lib/python2.7/dist-packages/celery/app/trace.py", line 240, in trace_task

    R = retval = fun(*args, **kwargs)

  File "/usr/lib/python2.7/dist-packages/celery/app/trace.py", line 438, in __protected_call__

    return self.run(*args, **kwargs)

  File "/usr/local/lib/python2.7/site-packages/airflow/executors/celery_executor.py", line 43, in execute_command

    raise AirflowException('Celery command failed')

AirflowException: Celery command failed

Thanks,

Chowduri M

[Frank Wang]

I had similar issue before. I found that the issue can be solved by restarting the web server and worker.  I hope someone else have better solutions

[Chowduri Manjunatha]

Thanks Frank,

Its working fine after restarting the web server, but I am looking for the alternatives if you found anything please let me know.