You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "ASF subversion and git services (JIRA)" <ji...@apache.org> on 2017/12/11 17:57:00 UTC

[jira] [Commented] (AIRFLOW-1840) Fix Celery config

    [ https://issues.apache.org/jira/browse/AIRFLOW-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16286353#comment-16286353 ] 

ASF subversion and git services commented on AIRFLOW-1840:
----------------------------------------------------------

Commit 30076f1e45c7db54b0ac4bc118617d9a00cb5b7d in incubator-airflow's branch refs/heads/master from [~Fokko]
[ https://git-wip-us.apache.org/repos/asf?p=incubator-airflow.git;h=30076f1 ]

[AIRFLOW-1840] Make celery configuration congruent with Celery 4

Explicitly set the celery backend from the config
and align the config
with the celery config as this might be confusing.

Closes #2806 from Fokko/AIRFLOW-1840-Fix-celery-
config


> Fix Celery config
> -----------------
>
>                 Key: AIRFLOW-1840
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-1840
>             Project: Apache Airflow
>          Issue Type: Bug
>            Reporter: Fokko Driesprong
>            Assignee: Fokko Driesprong
>
> While configuring the Celery executor I keep running into this problem:
> ==> /var/log/airflow/scheduler.log <==
> Traceback (most recent call last):
>   File "/usr/local/lib/python2.7/dist-packages/airflow/executors/celery_executor.py", line 83, in sync
>     state = async.state
>   File "/usr/local/lib/python2.7/dist-packages/celery/result.py", line 394, in state
>     return self._get_task_meta()['status']
>   File "/usr/local/lib/python2.7/dist-packages/celery/result.py", line 339, in _get_task_meta
>     return self._maybe_set_cache(self.backend.get_task_meta(self.id))
>   File "/usr/local/lib/python2.7/dist-packages/celery/backends/base.py", line 307, in get_task_meta
>     meta = self._get_task_meta_for(task_id)
> AttributeError: 'DisabledBackend' object has no attribute '_get_task_meta_for'



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)