python - 带有 SQS Boto 客户端错误的气流芹菜执行器

Question

我正在尝试使用所有配置启动调度程序。我面临以下错误

[2019-11-28 12:39:32,163] {credentials.py:1032} INFO - Found credentials in shared credentials file: ~/.aws/credentials
[2019-11-28 12:39:32,191] {connectionpool.py:735} INFO - Starting new HTTPS connection (1): ap-southeast-1.queue.amazonaws.com
[2019-11-28 12:39:32,258] {connectionpool.py:238} INFO - Resetting dropped connection: ap-southeast-1.queue.amazonaws.com
[2019-11-28 12:39:32,804] {connectionpool.py:238} INFO - Resetting dropped connection: ap-southeast-1.queue.amazonaws.com
[2019-11-28 12:39:32,844] {connectionpool.py:238} INFO - Resetting dropped connection: ap-southeast-1.queue.amazonaws.com
[2019-11-28 12:39:32,883] {connectionpool.py:238} INFO - Resetting dropped connection: ap-southeast-1.queue.amazonaws.com
Exception in thread Thread-3:
Traceback (most recent call last):
  File "/usr/lib/python3.5/threading.py", line 914, in _bootstrap_inner
    self.run()
  File "/usr/lib/python3.5/threading.py", line 862, in run
    self._target(*self._args, **self._kwargs)
  File "/usr/lib/python3.5/multiprocessing/pool.py", line 429, in _handle_results
    task = get()
  File "/usr/lib/python3.5/multiprocessing/connection.py", line 251, in recv
    return ForkingPickler.loads(buf.getbuffer())
TypeError: __init__() missing 1 required positional argument: 'operation_name'

此错误与 boto 库客户端有关吗？（我正在使用最新的 boto 客户端1.10.28和气流1.10.6）

蒂亚！

标签： pythonceleryboto3airflowairflow-scheduler