Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- [2017-01-13 09:01:55,470] {models.py:168} INFO - Filling up the DagBag from /opt/airflow/dags/long_task_new.py
- [2017-01-13 09:01:55,535] {jobs.py:2007} INFO - Subprocess PID is 33853
- [2017-01-13 09:01:56,910] {models.py:168} INFO - Filling up the DagBag from /opt/airflow/dags/long_task_new.py
- [2017-01-13 09:01:56,952] {models.py:1062} INFO - Dependencies all met for <TaskInstance: long_task_new_13.task1 2017-01-13 09:01:49.778417 [queued]>
- [2017-01-13 09:01:56,960] {models.py:1062} INFO - Dependencies all met for <TaskInstance: long_task_new_13.task1 2017-01-13 09:01:49.778417 [queued]>
- [2017-01-13 09:01:56,960] {models.py:1250} INFO -
- --------------------------------------------------------------------------------
- Starting attempt 1 of 1
- --------------------------------------------------------------------------------
- [2017-01-13 09:01:56,982] {models.py:1273} INFO - Executing <Task(PythonOperator): task1> on 2017-01-13 09:01:49.778417
- [2017-01-13 10:02:49,814] {models.py:168} INFO - Filling up the DagBag from /opt/airflow/dags/long_task_new.py
- [2017-01-13 10:02:49,877] {jobs.py:2007} INFO - Subprocess PID is 6401
- [2017-01-13 10:02:51,418] {models.py:168} INFO - Filling up the DagBag from /opt/airflow/dags/long_task_new.py
- [2017-01-13 10:02:51,464] {models.py:1059} WARNING - Dependencies not met for <TaskInstance: long_task_new_13.task1 2017-01-13 09:01:49.778417 [running]>, dependency 'Task Instance State' FAILED: Task is in the 'running' state which is not a valid state for execution. The task must be cleared in order to be run.
- [2017-01-13 10:02:52,206] {jobs.py:2076} WARNING - Recorded hostname and pid of hostname.domain.com and 6401 do not match this instance's which are hostname.domain.com and 33853. Taking the poison pill. So long.
- [2017-01-13 10:02:52,401] {helpers.py:207} WARNING - Terminating descendant processes of ['/opt/anaconda2/bin/python /opt/anaconda2/bin/airflow run long_task_new_13 task1 2017-01-13T09:01:49.778417 --local -sd /opt/airflow/dags/long_task_new.py'] PID: 33652
- [2017-01-13 10:02:52,402] {helpers.py:210} WARNING - Terminating descendant process ['/opt/anaconda2/bin/python /opt/anaconda2/bin/airflow run long_task_new_13 task1 2017-01-13T09:01:49.778417 --job_id 544297 --raw -sd DAGS_FOLDER/long_task_new.py'] PID: 33853
- [2017-01-13 10:02:52,402] {helpers.py:213} WARNING - Waiting up to 5s for processes to exit...
- [2017-01-13 10:02:52,402] {models.py:1282} ERROR - Killing subprocess
- [2017-01-13 10:02:52,403] {models.py:1348} ERROR - Task received SIGTERM signal
- Traceback (most recent call last):
- File "/opt/anaconda2/lib/python2.7/site-packages/airflow-1.7.2.dev0-py2.7.egg/airflow/models.py", line 1300, in run
- result = task_copy.execute(context=context)
- File "/opt/anaconda2/lib/python2.7/site-packages/airflow-1.7.2.dev0-py2.7.egg/airflow/operators/python_operator.py", line 80, in execute
- return_value = self.python_callable(*self.op_args, **self.op_kwargs)
- File "/opt/airflow/dags/long_task_new.py", line 19, in run
- time.sleep(n)
- File "/opt/anaconda2/lib/python2.7/site-packages/airflow-1.7.2.dev0-py2.7.egg/airflow/models.py", line 1284, in signal_handler
- raise AirflowException("Task received SIGTERM signal")
- AirflowException: Task received SIGTERM signal
- [2017-01-13 10:02:52,406] {models.py:1372} INFO - Marking task as FAILED.
- [2017-01-13 10:02:52,437] {email.py:101} INFO - Sent an alert email to ['[email protected]']
- [2017-01-13 10:02:52,488] {models.py:1393} ERROR - Task received SIGTERM signal
- [2017-01-13 10:02:52,655] {helpers.py:216} WARNING - Done waiting
Advertisement
Add Comment
Please, Sign In to add comment