Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Shutdown fails to cancel active tasks #6833

Closed
greenape opened this issue Oct 17, 2024 · 0 comments · Fixed by #6834
Closed

Shutdown fails to cancel active tasks #6833

greenape opened this issue Oct 17, 2024 · 0 comments · Fixed by #6834
Labels
bug Something isn't working FlowMachine Issues related to FlowMachine

Comments

@greenape
Copy link
Member

handle: <Handle shutdown(socket=<zmq.asyncio....452c10 closed>)() at /root/.local/share/virtualenvs/flowmachine-xFJaCIfC/lib/python3.12/site-packages/flowmachine/core/server/server.py:203>
Traceback (most recent call last):
  File "/usr/local/lib/python3.12/asyncio/events.py", line 88, in _run
    self._context.run(self._callback, *self._args)
  File "/root/.local/share/virtualenvs/flowmachine-xFJaCIfC/lib/python3.12/site-packages/flowmachine/core/server/server.py", line 212, in shutdown
    for task in asyncio.Task.all_tasks()
                ^^^^^^^^^^^^^^^^^^^^^^
AttributeError: type object '_asyncio.Task' has no attribute 'all_tasks'
Traceback (most recent call last):
  File "/root/.local/share/virtualenvs/flowmachine-xFJaCIfC/bin/flowmachine", line 8, in <module>
    sys.exit(main())
             ^^^^^^
  File "/root/.local/share/virtualenvs/flowmachine-xFJaCIfC/lib/python3.12/site-packages/flowmachine/core/server/server.py", line 273, in main
    asyncio.run(
  File "/usr/local/lib/python3.12/asyncio/runners.py", line 194, in run
    return runner.run(main)
           ^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/asyncio/runners.py", line 118, in run
    return self._loop.run_until_complete(task)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.12/asyncio/base_events.py", line 687, in run_until_complete
    return future.result()
           ^^^^^^^^^^^^^^^
  File "/root/.local/share/virtualenvs/flowmachine-xFJaCIfC/lib/python3.12/site-packages/flowmachine/core/server/server.py", line 249, in recv
    await receive_next_zmq_message_and_send_back_reply(
  File "/root/.local/share/virtualenvs/flowmachine-xFJaCIfC/lib/python3.12/site-packages/flowmachine/core/server/server.py", line 125, in receive_next_zmq_message_and_send_back_reply
    multipart_msg = await socket.recv_multipart()
                    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
asyncio.exceptions.CancelledError```
@greenape greenape added bug Something isn't working FlowMachine Issues related to FlowMachine labels Oct 17, 2024
greenape added a commit that referenced this issue Oct 17, 2024
greenape added a commit that referenced this issue Oct 17, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working FlowMachine Issues related to FlowMachine
Projects
None yet
Development

Successfully merging a pull request may close this issue.

1 participant