[
https://issues.apache.org/jira/browse/AIRFLOW-2323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16553216#comment-16553216
]
Kevin Yuen commented on AIRFLOW-2323:
-------------------------------------
This issue occurred to me today. I am running the following:
Airflow `1-10-stable`
Python 3.6.5
on Celery with rabbitmq broker
I installed apache-airflow[rabbitmq] and it caused the following error.
{code:java}
File
"/usr/local/lib/python3.6/dist-packages/airflow/executors/celery_executor.py",
line 87, in execute_async args=[command], queue=queue) File
"/usr/local/lib/python3.6/dist-packages/celery/app/task.py", line 535, in
apply_async **options File
"/usr/local/lib/python3.6/dist-packages/celery/app/base.py", line 728, in
send_task amqp.send_task_message(P, name, message, **options) File
"/usr/local/lib/python3.6/dist-packages/celery/app/amqp.py", line 552, in
send_task_message **properties File
"/usr/local/lib/python3.6/dist-packages/kombu/messaging.py", line 181, in
publish exchange_name, declare, File
"/usr/local/lib/python3.6/dist-packages/kombu/connection.py", line 494, in
_ensured return fun(*args, **kwargs) File
"/usr/local/lib/python3.6/dist-packages/kombu/messaging.py", line 203, in
_publish mandatory=mandatory, immediate=immediate, File
"/usr/local/lib/python3.6/dist-packages/librabbitmq/__init__.py", line 122, in
basic_publish mandatory or False, immediate or False, TypeError: an integer is
required (got type NoneType)
{code}
I def support the notion of moving to something Py3 friendly
> Should we replace the librabbitmq with other library in setup.py for Apache
> Airflow 1.9+?
> -----------------------------------------------------------------------------------------
>
> Key: AIRFLOW-2323
> URL: https://issues.apache.org/jira/browse/AIRFLOW-2323
> Project: Apache Airflow
> Issue Type: Bug
> Reporter: A.Quasimodo
> Priority: Major
>
> As we know, latest librabbitmq is still can't support Python3,so, when I
> executed the command *pip install apache-airflow[rabbitmq]*, some errors
> happened.
> So, should we replace the librabbitmq with other libraries like
> amqplib,py-amqp,.etc?
> Thank you
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
