We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bc9c93e commit 5de2ed9Copy full SHA for 5de2ed9
galahad/tasks/machine.py
@@ -109,19 +109,6 @@ def create_task(self, process):
109
)[0]
110
111
112
-class NonBlockingJoin(Join):
113
-
114
- def __call__(self, process, task):
115
- if task.child_task_set.exists():
116
- return tuple()
117
118
- def create_task(self, process):
119
- return process.task_set.get_or_create(
120
- node_name=self.node_name,
121
- node_type=self.node_type,
122
- )[0]
123
124
125
class Wait:
126
"""
127
Wait for a certain amount of time and then continue with the next tasks.
0 commit comments