Airflow LocalScheduler thread dump

Process 1:
# ThreadID: 139850429224704
File: "/usr/local/lib/python3.7/threading.py", line 890, in _bootstrap
  self._bootstrap_inner()
File: "/usr/local/lib/python3.7/threading.py", line 926, in _bootstrap_inner
  self.run()
File: "<string>", line 167, in run
File: "/usr/local/lib/python3.7/code.py", line 232, in interact
  more = self.push(line)
File: "/usr/local/lib/python3.7/code.py", line 258, in push
  more = self.runsource(source, self.filename)
File: "/usr/local/lib/python3.7/code.py", line 74, in runsource
  self.runcode(code)
File: "/usr/local/lib/python3.7/code.py", line 90, in runcode
  exec(code, self.locals)
File: "<console>", line 3, in <module>

# ThreadID: 139851735897856
File: "/usr/local/bin/airflow", line 37, in <module>
  args.func(args)
File: "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
  return f(*args, **kwargs)
File: "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 1042, in scheduler
  job.run()
File: "/usr/local/lib/python3.7/site-packages/airflow/jobs/base_job.py", line 222, in run
  self._execute()
File: "/usr/local/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 1356, in _execute
  self._execute_helper()
File: "/usr/local/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 1496, in _execute_helper
  self.executor.end()
File: "/usr/local/lib/python3.7/site-packages/airflow/executors/local_executor.py", line 233, in end
  self.impl.end()
File: "/usr/local/lib/python3.7/site-packages/airflow/executors/local_executor.py", line 212, in end
  self.queue.join()
File: "<string>", line 2, in join
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 819, in _callmethod
  kind, result = conn.recv()
File: "/usr/local/lib/python3.7/multiprocessing/connection.py", line 250, in recv
  buf = self._recv_bytes()
File: "/usr/local/lib/python3.7/multiprocessing/connection.py", line 407, in _recv_bytes
  buf = self._recv(4)
File: "/usr/local/lib/python3.7/multiprocessing/connection.py", line 379, in _recv
  chunk = read(handle, remaining)

Process 44:
File: "/usr/local/lib/python3.7/threading.py", line 890, in _bootstrap
  self._bootstrap_inner()
File: "/usr/local/lib/python3.7/threading.py", line 926, in _bootstrap_inner
  self.run()
File: "<string>", line 167, in run
File: "/usr/local/lib/python3.7/code.py", line 232, in interact
  more = self.push(line)
File: "/usr/local/lib/python3.7/code.py", line 258, in push
  more = self.runsource(source, self.filename)
File: "/usr/local/lib/python3.7/code.py", line 74, in runsource
  self.runcode(code)
File: "/usr/local/lib/python3.7/code.py", line 90, in runcode
  exec(code, self.locals)
File: "<console>", line 3, in <module>

# ThreadID: 139840628709120
File: "/usr/local/lib/python3.7/threading.py", line 890, in _bootstrap
  self._bootstrap_inner()
File: "/usr/local/lib/python3.7/threading.py", line 926, in _bootstrap_inner
  self.run()
File: "/usr/local/lib/python3.7/threading.py", line 870, in run
  self._target(*self._args, **self._kwargs)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 201, in handle_request
  result = func(c, *args, **kwds)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 422, in accept_connection
  self.serve_client(c)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 254, in serve_client
  res = function(*args, **kwds)
File: "/usr/local/lib/python3.7/queue.py", line 89, in join
  self.all_tasks_done.wait()
File: "/usr/local/lib/python3.7/threading.py", line 296, in wait
  waiter.acquire()

# ThreadID: 139850429224704
File: "/usr/local/lib/python3.7/threading.py", line 890, in _bootstrap
  self._bootstrap_inner()
File: "/usr/local/lib/python3.7/threading.py", line 926, in _bootstrap_inner
  self.run()
File: "/usr/local/lib/python3.7/threading.py", line 870, in run
  self._target(*self._args, **self._kwargs)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 178, in accepter
  c = self.listener.accept()
File: "/usr/local/lib/python3.7/multiprocessing/connection.py", line 453, in accept
  c = self._listener.accept()
File: "/usr/local/lib/python3.7/multiprocessing/connection.py", line 598, in accept
  s, self._last_accepted = self._socket.accept()
File: "/usr/local/lib/python3.7/socket.py", line 212, in accept
  fd, addr = self._accept()

# ThreadID: 139851735897856
File: "/usr/local/bin/airflow", line 37, in <module>
  args.func(args)
File: "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
  return f(*args, **kwargs)
File: "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 1042, in scheduler
  job.run()
File: "/usr/local/lib/python3.7/site-packages/airflow/jobs/base_job.py", line 222, in run
  self._execute()
File: "/usr/local/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 1356, in _execute
  self._execute_helper()
File: "/usr/local/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 1380, in _execute_helper
  self.executor.start()
File: "/usr/local/lib/python3.7/site-packages/airflow/executors/local_executor.py", line 216, in start
  self.manager = multiprocessing.Manager()
File: "/usr/local/lib/python3.7/multiprocessing/context.py", line 56, in Manager
  m.start()
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 563, in start
  self._process.start()
File: "/usr/local/lib/python3.7/multiprocessing/process.py", line 112, in start
  self._popen = self._Popen(self)
File: "/usr/local/lib/python3.7/multiprocessing/context.py", line 277, in _Popen
  return Popen(process_obj)
File: "/usr/local/lib/python3.7/multiprocessing/popen_fork.py", line 20, in __init__
  self._launch(process_obj)
File: "/usr/local/lib/python3.7/multiprocessing/popen_fork.py", line 74, in _launch
  code = process_obj._bootstrap()
File: "/usr/local/lib/python3.7/multiprocessing/process.py", line 297, in _bootstrap
  self.run()
File: "/usr/local/lib/python3.7/multiprocessing/process.py", line 99, in run
  self._target(*self._args, **self._kwargs)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 597, in _run_server
  server.serve_forever()
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 165, in serve_forever
  self.stop_event.wait(1)
File: "/usr/local/lib/python3.7/threading.py", line 552, in wait
  signaled = self._cond.wait(timeout)
File: "/usr/local/lib/python3.7/threading.py", line 300, in wait
  gotit = waiter.acquire(True, timeout)

Process 43:

# ThreadID: 139847666747136
File: "/usr/local/lib/python3.7/threading.py", line 890, in _bootstrap
  self._bootstrap_inner()
File: "/usr/local/lib/python3.7/threading.py", line 926, in _bootstrap_inner
  self.run()
File: "<string>", line 167, in run
File: "/usr/local/lib/python3.7/code.py", line 232, in interact
  more = self.push(line)
File: "/usr/local/lib/python3.7/code.py", line 258, in push
  more = self.runsource(source, self.filename)
File: "/usr/local/lib/python3.7/code.py", line 74, in runsource
  self.runcode(code)
File: "/usr/local/lib/python3.7/code.py", line 90, in runcode
  exec(code, self.locals)
File: "<console>", line 3, in <module>

# ThreadID: 139840628709120
File: "/usr/local/lib/python3.7/threading.py", line 890, in _bootstrap
  self._bootstrap_inner()
File: "/usr/local/lib/python3.7/threading.py", line 926, in _bootstrap_inner
  self.run()
File: "/usr/local/lib/python3.7/threading.py", line 870, in run
  self._target(*self._args, **self._kwargs)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 201, in handle_request
  result = func(c, *args, **kwds)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 422, in accept_connection
  self.serve_client(c)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 254, in serve_client
  res = function(*args, **kwds)
File: "/usr/local/lib/python3.7/queue.py", line 89, in join
  self.all_tasks_done.wait()
File: "/usr/local/lib/python3.7/threading.py", line 296, in wait
  waiter.acquire()

# ThreadID: 139850429224704
File: "/usr/local/lib/python3.7/threading.py", line 890, in _bootstrap
  self._bootstrap_inner()
File: "/usr/local/lib/python3.7/threading.py", line 926, in _bootstrap_inner
  self.run()
File: "/usr/local/lib/python3.7/threading.py", line 870, in run
  self._target(*self._args, **self._kwargs)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 178, in accepter
  c = self.listener.accept()
File: "/usr/local/lib/python3.7/multiprocessing/connection.py", line 453, in accept
  c = self._listener.accept()
File: "/usr/local/lib/python3.7/multiprocessing/connection.py", line 598, in accept
  s, self._last_accepted = self._socket.accept()
File: "/usr/local/lib/python3.7/socket.py", line 212, in accept
  fd, addr = self._accept()

# ThreadID: 139851735897856
File: "/usr/local/bin/airflow", line 37, in <module>
  args.func(args)
File: "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
  return f(*args, **kwargs)
File: "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 1042, in scheduler
  job.run()
File: "/usr/local/lib/python3.7/site-packages/airflow/jobs/base_job.py", line 222, in run
  self._execute()
File: "/usr/local/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 1356, in _execute
  self._execute_helper()
File: "/usr/local/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 1380, in _execute_helper
  self.executor.start()
File: "/usr/local/lib/python3.7/site-packages/airflow/executors/local_executor.py", line 216, in start
  self.manager = multiprocessing.Manager()
File: "/usr/local/lib/python3.7/multiprocessing/context.py", line 56, in Manager
  m.start()
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 563, in start
  self._process.start()
File: "/usr/local/lib/python3.7/multiprocessing/process.py", line 112, in start
  self._popen = self._Popen(self)
File: "/usr/local/lib/python3.7/multiprocessing/context.py", line 277, in _Popen
  return Popen(process_obj)
File: "/usr/local/lib/python3.7/multiprocessing/popen_fork.py", line 20, in __init__
  self._launch(process_obj)
File: "/usr/local/lib/python3.7/multiprocessing/popen_fork.py", line 74, in _launch
  code = process_obj._bootstrap()
File: "/usr/local/lib/python3.7/multiprocessing/process.py", line 297, in _bootstrap
  self.run()
File: "/usr/local/lib/python3.7/multiprocessing/process.py", line 99, in run
  self._target(*self._args, **self._kwargs)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 597, in _run_server
  server.serve_forever()
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 165, in serve_forever
  self.stop_event.wait(1)
File: "/usr/local/lib/python3.7/threading.py", line 552, in wait
  signaled = self._cond.wait(timeout)
File: "/usr/local/lib/python3.7/threading.py", line 300, in wait
  gotit = waiter.acquire(True, timeout)

Process 566:
# ThreadID: 139847666747136
File: "/usr/local/lib/python3.7/threading.py", line 890, in _bootstrap
  self._bootstrap_inner()
File: "/usr/local/lib/python3.7/threading.py", line 926, in _bootstrap_inner
  self.run()
File: "<string>", line 167, in run
File: "/usr/local/lib/python3.7/code.py", line 232, in interact
  more = self.push(line)
File: "/usr/local/lib/python3.7/code.py", line 258, in push
  more = self.runsource(source, self.filename)
File: "/usr/local/lib/python3.7/code.py", line 74, in runsource
  self.runcode(code)
File: "/usr/local/lib/python3.7/code.py", line 90, in runcode
  exec(code, self.locals)
File: "<console>", line 3, in <module>

# ThreadID: 139840628709120
File: "/usr/local/lib/python3.7/threading.py", line 890, in _bootstrap
  self._bootstrap_inner()
File: "/usr/local/lib/python3.7/threading.py", line 926, in _bootstrap_inner
  self.run()
File: "/usr/local/lib/python3.7/threading.py", line 870, in run
  self._target(*self._args, **self._kwargs)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 201, in handle_request
  result = func(c, *args, **kwds)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 422, in accept_connection
  self.serve_client(c)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 254, in serve_client
  res = function(*args, **kwds)
File: "/usr/local/lib/python3.7/queue.py", line 89, in join
  self.all_tasks_done.wait()
File: "/usr/local/lib/python3.7/threading.py", line 296, in wait
  waiter.acquire()

# ThreadID: 139850429224704
File: "/usr/local/lib/python3.7/threading.py", line 890, in _bootstrap
  self._bootstrap_inner()
File: "/usr/local/lib/python3.7/threading.py", line 926, in _bootstrap_inner
  self.run()
File: "/usr/local/lib/python3.7/threading.py", line 870, in run
  self._target(*self._args, **self._kwargs)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 178, in accepter
  c = self.listener.accept()
File: "/usr/local/lib/python3.7/multiprocessing/connection.py", line 453, in accept
  c = self._listener.accept()
File: "/usr/local/lib/python3.7/multiprocessing/connection.py", line 598, in accept
  s, self._last_accepted = self._socket.accept()
File: "/usr/local/lib/python3.7/socket.py", line 212, in accept
  fd, addr = self._accept()

# ThreadID: 139851735897856
File: "/usr/local/bin/airflow", line 37, in <module>
  args.func(args)
File: "/usr/local/lib/python3.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
  return f(*args, **kwargs)
File: "/usr/local/lib/python3.7/site-packages/airflow/bin/cli.py", line 1042, in scheduler
  job.run()
File: "/usr/local/lib/python3.7/site-packages/airflow/jobs/base_job.py", line 222, in run
  self._execute()
File: "/usr/local/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 1356, in _execute
  self._execute_helper()
File: "/usr/local/lib/python3.7/site-packages/airflow/jobs/scheduler_job.py", line 1380, in _execute_helper
  self.executor.start()
File: "/usr/local/lib/python3.7/site-packages/airflow/executors/local_executor.py", line 216, in start
  self.manager = multiprocessing.Manager()
File: "/usr/local/lib/python3.7/multiprocessing/context.py", line 56, in Manager
  m.start()
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 563, in start
  self._process.start()
File: "/usr/local/lib/python3.7/multiprocessing/process.py", line 112, in start
  self._popen = self._Popen(self)
File: "/usr/local/lib/python3.7/multiprocessing/context.py", line 277, in _Popen
  return Popen(process_obj)
File: "/usr/local/lib/python3.7/multiprocessing/popen_fork.py", line 20, in __init__
  self._launch(process_obj)
File: "/usr/local/lib/python3.7/multiprocessing/popen_fork.py", line 74, in _launch
  code = process_obj._bootstrap()
File: "/usr/local/lib/python3.7/multiprocessing/process.py", line 297, in _bootstrap
  self.run()
File: "/usr/local/lib/python3.7/multiprocessing/process.py", line 99, in run
  self._target(*self._args, **self._kwargs)
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 597, in _run_server
  server.serve_forever()
File: "/usr/local/lib/python3.7/multiprocessing/managers.py", line 165, in serve_forever
  self.stop_event.wait(1)
File: "/usr/local/lib/python3.7/threading.py", line 552, in wait
  signaled = self._cond.wait(timeout)
File: "/usr/local/lib/python3.7/threading.py", line 300, in wait
  gotit = waiter.acquire(True, timeout)