Mailing-List: contact commits-help@airflow.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@airflow.incubator.apache.org
Date: Mon, 6 Feb 2017 14:32:42 +0000 (UTC)
From: "abhijeet dada mote (JIRA)" <jira@apache.org>
To: commits@airflow.incubator.apache.org
Message-ID: <JIRA.13040646.1486390229000.5979.1486391562003@Atlassian.JIRA>
In-Reply-To: <JIRA.13040646.1486390229000@Atlassian.JIRA>
References: <JIRA.13040646.1486390229000@Atlassian.JIRA> <JIRA.13040646.1486390229832@jira-lw-us.apache.org>
Subject: [jira] [Updated] (AIRFLOW-841) "OperationalError: Couldn't log in:
 a socket error occurred" when using web UI
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Mon, 06 Feb 2017 14:32:49 -0000


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

abhijeet dada mote updated AIRFLOW-841:
---------------------------------------
    Attachment: airflow.cfg

> "OperationalError: Couldn't log in: a socket error occurred" when using web UI
> ------------------------------------------------------------------------------
>
>                 Key: AIRFLOW-841
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-841
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: celery, executor, scheduler, ui
>            Reporter: abhijeet dada mote
>            Assignee: Siddharth Anand
>              Labels: beginner, triaged
>         Attachments: airflow.cfg, hello.py, print_range.py
>
>
> Hi All,
> I am getting following error when I am trying to run my workflow using UI.
> Can anyone help me to resolve this problem? 
> *OperationalError: Couldn't log in: a socket error occurred*
> {code}
> Traceback (most recent call last):
>   File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1817, in wsgi_app
>     response = self.full_dispatch_request()
>   File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1477, in full_dispatch_request
>     rv = self.handle_user_exception(e)
>   File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1381, in handle_user_exception
>     reraise(exc_type, exc_value, tb)
>   File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1475, in full_dispatch_request
>     rv = self.dispatch_request()
>   File "/usr/local/lib/python2.7/dist-packages/flask/app.py", line 1461, in dispatch_request
>     return self.view_functions[rule.endpoint](**req.view_args)
>   File "/usr/local/lib/python2.7/dist-packages/flask_admin/base.py", line 68, in inner
>     return self._run_view(f, *args, **kwargs)
>   File "/usr/local/lib/python2.7/dist-packages/flask_admin/base.py", line 367, in _run_view
>     return fn(self, *args, **kwargs)
>   File "/usr/local/lib/python2.7/dist-packages/flask_login.py", line 755, in decorated_view
>     return func(*args, **kwargs)
>   File "/usr/local/lib/python2.7/dist-packages/airflow/www/utils.py", line 118, in wrapper
>     return f(*args, **kwargs)
>   File "/usr/local/lib/python2.7/dist-packages/airflow/www/utils.py", line 167, in wrapper
>     return f(*args, **kwargs)
>   File "/usr/local/lib/python2.7/dist-packages/airflow/www/views.py", line 989, in run
>     executor.heartbeat()
>   File "/usr/local/lib/python2.7/dist-packages/airflow/executors/base_executor.py", line 99, in heartbeat
>     self.execute_async(key, command=command, queue=queue)
>   File "/usr/local/lib/python2.7/dist-packages/airflow/executors/celery_executor.py", line 66, in execute_async
>     args=[command], queue=queue)
>   File "/usr/local/lib/python2.7/dist-packages/celery/app/task.py", line 535, in apply_async
>     **options
>   File "/usr/local/lib/python2.7/dist-packages/celery/app/base.py", line 737, in send_task
>     amqp.send_task_message(P, name, message, **options)
>   File "/usr/local/lib/python2.7/dist-packages/celery/app/amqp.py", line 558, in send_task_message
>     **properties
>   File "/usr/local/lib/python2.7/dist-packages/kombu/messaging.py", line 181, in publish
>     exchange_name, declare,
>   File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 527, in _ensured
>     errback and errback(exc, 0)
>   File "/usr/lib/python2.7/contextlib.py", line 35, in __exit__
>     self.gen.throw(type, value, traceback)
>   File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 419, in _reraise_as_library_errors
>     sys.exc_info()[2])
>   File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 414, in _reraise_as_library_errors
>     yield
>   File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 515, in _ensured
>     reraise_as_library_errors=False,
>   File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 405, in ensure_connection
>     callback)
>   File "/usr/local/lib/python2.7/dist-packages/kombu/utils/functional.py", line 333, in retry_over_time
>     return fun(*args, **kwargs)
>   File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 261, in connect
>     return self.connection
>   File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 802, in connection
>     self._connection = self._establish_connection()
>   File "/usr/local/lib/python2.7/dist-packages/kombu/connection.py", line 757, in _establish_connection
>     conn = self.transport.establish_connection()
>   File "/usr/local/lib/python2.7/dist-packages/kombu/transport/librabbitmq.py", line 132, in establish_connection
>     conn = self.Connection(**opts)
>   File "/usr/local/lib/python2.7/dist-packages/librabbitmq/__init__.py", line 199, in __init__
>     self.connect()
> OperationalError: Couldn't log in: a socket error occurred
> {code}
> I have made the changes in _/home/ubuntu/airflow/airflow.cfg_ file.
> Commented the default setting to new one(changes are displayed below).
> {code}
> # executor = SequentialExecutor
> executor = CeleryExecutor
> # sql_alchemy_conn = sqlite:////home/ubuntu/airflow/airflow.db
> sql_alchemy_conn =  postgresql+psycopg2://airflow:airflow_demo@localhost:5432/airflow_demo
> # broker_url = sqla+mysql://airflow:airflow@localhost:3306/airflow
> broker_url = amqp://airflow:airflow_demo@localhost:5672/airflow_demo
> # celery_result_backend = db+mysql://airflow:airflow@localhost:3306/airflow
> celery_result_backend = db+postgresql://airflow:airflow_demo@localhost:5432/airflow_demo
> {code}
> To perform the activity through UI:
> #    I have installed Celery(because UI activity only works with celery executor)
> #    Installed rabitmq and created the user and given the permissions.
> #    Installed postgresql and dependent packages, added required URL string.
> #    I also have created the required user with permissions using rabitmqadmin.
> #    But facing the error which is mentioned above.
> Is there any dependency of flower service on airflow. The dags which I have created using CeleryExecutor is working fine through command line but not working in UI.
> [~nickt], [~criccomini], [~maxime.beauchemin@apache.org]. Can you please help me to resolve this issue. 
> Thanks in Advance,
> Abhijeet


--
This message was sent by Atlassian JIRA
(v6.3.15#6346)