Та же самая настройка работает на Ma c и перемещает изображения и создает файл на сервер CentOS. Сначала у меня были проблемы с маршрутами, и я решил их путем обновления правил с помощью firewalld.
scheduler_1 | Celery Task ID: ('parallel_dag', 'task_4', datetime.datetime(2020, 3, 17, 0, 0, tzinfo=<TimezoneInfo [UTC, GMT, +00:00:00, STD]>), 1)
scheduler_1 | Traceback (most recent call last):
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/kombu/utils/functional.py", line 42, in __call__
scheduler_1 | return self.__value__
scheduler_1 | AttributeError: 'ChannelPromise' object has no attribute '__value__'
scheduler_1 |
scheduler_1 | During handling of the above exception, another exception occurred:
scheduler_1 |
scheduler_1 | Traceback (most recent call last):
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/kombu/transport/virtual/base.py", line 921, in create_channel
scheduler_1 | return self._avail_channels.pop()
scheduler_1 | IndexError: pop from empty list
scheduler_1 |
scheduler_1 | During handling of the above exception, another exception occurred:
scheduler_1 |
scheduler_1 | Traceback (most recent call last):
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/airflow/executors/celery_executor.py", line 118, in send_task_to_executor
scheduler_1 | result = task.apply_async(args=[command], queue=queue)
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/celery/app/task.py", line 570, in apply_async
scheduler_1 | **options
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/celery/app/base.py", line 756, in send_task
scheduler_1 | amqp.send_task_message(P, name, message, **options)
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/celery/app/amqp.py", line 552, in send_task_message
scheduler_1 | **properties
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/kombu/messaging.py", line 181, in publish
scheduler_1 | exchange_name, declare,
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/kombu/connection.py", line 510, in _ensured
scheduler_1 | return fun(*args, **kwargs)
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/kombu/messaging.py", line 187, in _publish
scheduler_1 | channel = self.channel
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/kombu/messaging.py", line 209, in _get_channel
scheduler_1 | channel = self._channel = channel()
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/kombu/utils/functional.py", line 44, in __call__
scheduler_1 | value = self.__value__ = self.__contract__()
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/kombu/messaging.py", line 224, in <lambda>
scheduler_1 | channel = ChannelPromise(lambda: connection.default_channel)
scheduler_1 | File "/usr/local/lib/python3.7/site-packages/kombu/connection.py", line 852, in default_channel
scheduler_1 | self.ensure_connection(**conn_opts)