Skip to content

Conversation

@tobiasraabe
Copy link
Member

@tobiasraabe tobiasraabe commented May 4, 2024

@tobiasraabe tobiasraabe added this to the v0.5.0 milestone May 4, 2024
@tobiasraabe
Copy link
Member Author

tobiasraabe commented May 7, 2024

The PR includes an implementation where the status of tasks is shared with some shared object. No clue why the pickle error exist when running the test suite with tox, but not without it.

@tobiasraabe tobiasraabe removed this from the v0.5.0 milestone May 26, 2024
@tobiasraabe
Copy link
Member Author

Merged main into this branch, then switched pending→running tracking to a start-event queue:

  • manager queue for processes/loky
  • SimpleQueue for threads
  • wrappers emit start events; main loop drains queue to mark RUNNING
    I also restored task submission to "n_workers - len(running_tasks)" to preserve max_failures and priority behavior.

Tests:

  • uv run --group test pytest tests\test_execute.py -k "stop_execution_when_max_failures_is_reached or task_priorities"
  • uv run --group test pytest

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Implement a status pending.

2 participants