Skip to content

Fix key error when removing a dependency which doesn't exist when concurrently applying a function to a DAG#41

Merged
izeigerman merged 1 commit intomainfrom
fix-concurrent-apply-to-dag
Dec 11, 2022
Merged

Fix key error when removing a dependency which doesn't exist when concurrently applying a function to a DAG#41
izeigerman merged 1 commit intomainfrom
fix-concurrent-apply-to-dag

Conversation

@izeigerman
Copy link
Copy Markdown
Collaborator

This PR fixes 2 issues:

  1. Removal of a dependency which doesn't exist in a Set which was causing a KeyError. Changed .remove() to .discard().
  2. Setting the value of the finished_future when all tasks have been finished as opposed to when all tasks have been submitted.

@izeigerman izeigerman force-pushed the fix-concurrent-apply-to-dag branch from 6f5cb7e to cfe08b1 Compare December 10, 2022 21:57
@izeigerman izeigerman force-pushed the fix-concurrent-apply-to-dag branch from cfe08b1 to 50113bb Compare December 10, 2022 21:59
@izeigerman izeigerman merged commit 909d6d6 into main Dec 11, 2022
@izeigerman izeigerman deleted the fix-concurrent-apply-to-dag branch December 11, 2022 03:39
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.

2 participants