komuw / wiji

Wiji is an asyncio distributed task processor/queue.
MIT License
4 stars 1 forks source link

Issues/73:: #76

Open komuw opened 5 years ago

komuw commented 5 years ago

Thank you for contributing to wiji.
Every contribution to wiji is important.

Contributor offers to license certain software (a “Contribution” or multiple “Contributions”) to wiji, and wiji agrees to accept said Contributions, under the terms of the MIT License. Contributor understands and agrees that wiji shall have the irrevocable and perpetual right to make and distribute copies of any Contribution, as well as to create and distribute collective works and derivative works of any Contribution, under the MIT License.

Now,

What(What have you changed?)

Why(Why did you change it?)

References:

komuw commented 5 years ago
RuntimeError: Task <Task pending coro=<Worker.consume_tasks() running at /Users/komuw/mystuff/wiji/wiji/worker.py:269> created at /Users/komuw/mystuff/wiji/cli/cli.py:109> got Future <Future pending cb=[_chain_future.<locals>._call_check_cancel() at /usr/local/Cellar/python/3.7.0/Frameworks/Python.framework/Versions/3.7/lib/python3.7/asyncio/futures.py:348] created at /usr/local/Cellar/python/3.7.0/Frameworks/Python.framework/Versions/3.7/lib/python3.7/asyncio/base_events.py:377> attached to a different loop

attached to a different loop; this thread per task idea will be very hard to pull off.

komuw commented 5 years ago

NB: logging is not multi process safe but it is thread safe