airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Andre (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (AIRFLOW-172) All example DAGs report "Only works with the CeleryExecutor, sorry"
Date Wed, 25 May 2016 05:26:13 GMT

     [ https://issues.apache.org/jira/browse/AIRFLOW-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Andre updated AIRFLOW-172:
--------------------------
    Description: 
After installing airflow and trying to run some example DAGs I was faced with 

{{Only works with the CeleryExecutor, sorry}}

on every DAG I tried to run.

{code}$ pip list
airflow (1.7.1.2)
alembic (0.8.6)
Babel (1.3)
bitarray (0.8.1)
cffi (1.6.0)
chartkick (0.4.2)
croniter (0.3.12)
cryptography (1.3.2)
dill (0.2.5)
docutils (0.12)
Flask (0.10.1)
Flask-Admin (1.4.0)
Flask-Cache (0.13.1)
Flask-Login (0.2.11)
Flask-WTF (0.12)
funcsigs (0.4)
future (0.15.2)
google-apputils (0.4.2)
gunicorn (19.3.0)
hive-thrift-py (0.0.1)
idna (2.1)
impyla (0.13.7)
itsdangerous (0.24)
Jinja2 (2.8)
lockfile (0.12.2)
Mako (1.0.4)
Markdown (2.6.6)
MarkupSafe (0.23)
mysqlclient (1.3.7)
numpy (1.11.0)
pandas (0.18.1)
pip (8.1.2)
ply (3.8)
protobuf (2.6.1)
pyasn1 (0.1.9)
pycparser (2.14)
Pygments (2.1.3)
PyHive (0.1.8)
pykerberos (1.1.10)
python-daemon (2.1.1)
python-dateutil (2.5.3)
python-editor (1.0)
python-gflags (3.0.5)
pytz (2016.4)
requests (2.10.0)
setproctitle (1.1.10)
setuptools (21.2.1)
six (1.10.0)
snakebite (2.9.0)
SQLAlchemy (1.0.13)
thrift (0.9.3)
thriftpy (0.3.8)
unicodecsv (0.14.1)
Werkzeug (0.11.10)
WTForms (2.1)
{code}


{code}
$ airflow webserver -p 8088
[2016-05-25 15:22:48,204] {__init__.py:36} INFO - Using executor LocalExecutor
  ____________       _____________
 ____    |__( )_________  __/__  /________      __
____  /| |_  /__  ___/_  /_ __  /_  __ \_ | /| / /
___  ___ |  / _  /   _  __/ _  / / /_/ /_ |/ |/ /
 _/_/  |_/_/  /_/    /_/    /_/  \____/____/|__/

[2016-05-25 15:22:49,066] {models.py:154} INFO - Filling up the DagBag from /opt/airflow/production/dags
Running the Gunicorn server with 4 syncworkers on host 0.0.0.0 and port 8088 with a timeout
of 120...
[2016-05-25 15:22:49 +1000] [20191] [INFO] Starting gunicorn 19.3.0
[2016-05-25 15:22:49 +1000] [20191] [INFO] Listening at: http://0.0.0.0:8088 (20191)
[2016-05-25 15:22:49 +1000] [20191] [INFO] Using worker: sync
[2016-05-25 15:22:49 +1000] [20197] [INFO] Booting worker with pid: 20197
[2016-05-25 15:22:49 +1000] [20198] [INFO] Booting worker with pid: 20198
[2016-05-25 15:22:49 +1000] [20199] [INFO] Booting worker with pid: 20199
[2016-05-25 15:22:49 +1000] [20200] [INFO] Booting worker with pid: 20200
[2016-05-25 15:22:50,086] {__init__.py:36} INFO - Using executor LocalExecutor
[2016-05-25 15:22:50,176] {__init__.py:36} INFO - Using executor LocalExecutor
[2016-05-25 15:22:50,262] {__init__.py:36} INFO - Using executor LocalExecutor
[2016-05-25 15:22:50,364] {__init__.py:36} INFO - Using executor LocalExecutor
[2016-05-25 15:22:50,931] {models.py:154} INFO - Filling up the DagBag from /opt/airflow/production/dags
[2016-05-25 15:22:51,000] {models.py:154} INFO - Filling up the DagBag from /opt/airflow/production/dags
[2016-05-25 15:22:51,093] {models.py:154} INFO - Filling up the DagBag from /opt/airflow/production/dags
[2016-05-25 15:22:51,191] {models.py:154} INFO - Filling up the DagBag from /opt/airflow/production/dags

{code}

  was:
After installing airflow and trying to run some example DAGs I was faced with 

{{Only works with the CeleryExecutor, sorry}}

on every DAG I tried to run.

{code}$ pip list
airflow (1.7.1.2)
alembic (0.8.6)
Babel (1.3)
bitarray (0.8.1)
cffi (1.6.0)
chartkick (0.4.2)
croniter (0.3.12)
cryptography (1.3.2)
dill (0.2.5)
docutils (0.12)
Flask (0.10.1)
Flask-Admin (1.4.0)
Flask-Cache (0.13.1)
Flask-Login (0.2.11)
Flask-WTF (0.12)
funcsigs (0.4)
future (0.15.2)
google-apputils (0.4.2)
gunicorn (19.3.0)
hive-thrift-py (0.0.1)
idna (2.1)
impyla (0.13.7)
itsdangerous (0.24)
Jinja2 (2.8)
lockfile (0.12.2)
Mako (1.0.4)
Markdown (2.6.6)
MarkupSafe (0.23)
mysqlclient (1.3.7)
numpy (1.11.0)
pandas (0.18.1)
pip (8.1.2)
ply (3.8)
protobuf (2.6.1)
pyasn1 (0.1.9)
pycparser (2.14)
Pygments (2.1.3)
PyHive (0.1.8)
pykerberos (1.1.10)
python-daemon (2.1.1)
python-dateutil (2.5.3)
python-editor (1.0)
python-gflags (3.0.5)
pytz (2016.4)
requests (2.10.0)
setproctitle (1.1.10)
setuptools (21.2.1)
six (1.10.0)
snakebite (2.9.0)
SQLAlchemy (1.0.13)
thrift (0.9.3)
thriftpy (0.3.8)
unicodecsv (0.14.1)
Werkzeug (0.11.10)
WTForms (2.1)
{code}


> All example DAGs report "Only works with the CeleryExecutor, sorry"
> -------------------------------------------------------------------
>
>                 Key: AIRFLOW-172
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-172
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: executor
>    Affects Versions: Airflow 1.7.1
>            Reporter: Andre
>
> After installing airflow and trying to run some example DAGs I was faced with 
> {{Only works with the CeleryExecutor, sorry}}
> on every DAG I tried to run.
> {code}$ pip list
> airflow (1.7.1.2)
> alembic (0.8.6)
> Babel (1.3)
> bitarray (0.8.1)
> cffi (1.6.0)
> chartkick (0.4.2)
> croniter (0.3.12)
> cryptography (1.3.2)
> dill (0.2.5)
> docutils (0.12)
> Flask (0.10.1)
> Flask-Admin (1.4.0)
> Flask-Cache (0.13.1)
> Flask-Login (0.2.11)
> Flask-WTF (0.12)
> funcsigs (0.4)
> future (0.15.2)
> google-apputils (0.4.2)
> gunicorn (19.3.0)
> hive-thrift-py (0.0.1)
> idna (2.1)
> impyla (0.13.7)
> itsdangerous (0.24)
> Jinja2 (2.8)
> lockfile (0.12.2)
> Mako (1.0.4)
> Markdown (2.6.6)
> MarkupSafe (0.23)
> mysqlclient (1.3.7)
> numpy (1.11.0)
> pandas (0.18.1)
> pip (8.1.2)
> ply (3.8)
> protobuf (2.6.1)
> pyasn1 (0.1.9)
> pycparser (2.14)
> Pygments (2.1.3)
> PyHive (0.1.8)
> pykerberos (1.1.10)
> python-daemon (2.1.1)
> python-dateutil (2.5.3)
> python-editor (1.0)
> python-gflags (3.0.5)
> pytz (2016.4)
> requests (2.10.0)
> setproctitle (1.1.10)
> setuptools (21.2.1)
> six (1.10.0)
> snakebite (2.9.0)
> SQLAlchemy (1.0.13)
> thrift (0.9.3)
> thriftpy (0.3.8)
> unicodecsv (0.14.1)
> Werkzeug (0.11.10)
> WTForms (2.1)
> {code}
> {code}
> $ airflow webserver -p 8088
> [2016-05-25 15:22:48,204] {__init__.py:36} INFO - Using executor LocalExecutor
>   ____________       _____________
>  ____    |__( )_________  __/__  /________      __
> ____  /| |_  /__  ___/_  /_ __  /_  __ \_ | /| / /
> ___  ___ |  / _  /   _  __/ _  / / /_/ /_ |/ |/ /
>  _/_/  |_/_/  /_/    /_/    /_/  \____/____/|__/
> [2016-05-25 15:22:49,066] {models.py:154} INFO - Filling up the DagBag from /opt/airflow/production/dags
> Running the Gunicorn server with 4 syncworkers on host 0.0.0.0 and port 8088 with a timeout
of 120...
> [2016-05-25 15:22:49 +1000] [20191] [INFO] Starting gunicorn 19.3.0
> [2016-05-25 15:22:49 +1000] [20191] [INFO] Listening at: http://0.0.0.0:8088 (20191)
> [2016-05-25 15:22:49 +1000] [20191] [INFO] Using worker: sync
> [2016-05-25 15:22:49 +1000] [20197] [INFO] Booting worker with pid: 20197
> [2016-05-25 15:22:49 +1000] [20198] [INFO] Booting worker with pid: 20198
> [2016-05-25 15:22:49 +1000] [20199] [INFO] Booting worker with pid: 20199
> [2016-05-25 15:22:49 +1000] [20200] [INFO] Booting worker with pid: 20200
> [2016-05-25 15:22:50,086] {__init__.py:36} INFO - Using executor LocalExecutor
> [2016-05-25 15:22:50,176] {__init__.py:36} INFO - Using executor LocalExecutor
> [2016-05-25 15:22:50,262] {__init__.py:36} INFO - Using executor LocalExecutor
> [2016-05-25 15:22:50,364] {__init__.py:36} INFO - Using executor LocalExecutor
> [2016-05-25 15:22:50,931] {models.py:154} INFO - Filling up the DagBag from /opt/airflow/production/dags
> [2016-05-25 15:22:51,000] {models.py:154} INFO - Filling up the DagBag from /opt/airflow/production/dags
> [2016-05-25 15:22:51,093] {models.py:154} INFO - Filling up the DagBag from /opt/airflow/production/dags
> [2016-05-25 15:22:51,191] {models.py:154} INFO - Filling up the DagBag from /opt/airflow/production/dags
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message