We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9f10e82 commit abc4230Copy full SHA for abc4230
src/aws_durable_execution_sdk_python/concurrency/models.py
@@ -415,15 +415,7 @@ def is_complete(self) -> bool:
415
416
# All tasks completed
417
if completed_count == self.total_tasks:
418
- # Complete if no failure tolerance OR no failures OR min successful reached
419
- return (
420
- (
421
- self.tolerated_failure_count is None
422
- and self.tolerated_failure_percentage is None
423
- )
424
- or self.failure_count == 0
425
- or self.success_count >= self.min_successful
426
+ return True
427
428
# when we breach min successful, we've completed
429
return self.success_count >= self.min_successful
0 commit comments