Skip to content

Commit 74d82a2

Browse files
committed
minor fix
1 parent a82a672 commit 74d82a2

File tree

1 file changed

+7
-11
lines changed

1 file changed

+7
-11
lines changed

test/workforce/test_workforce_callbacks.py

Lines changed: 7 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,9 @@ def test_workforce_callback_registration_and_metrics_handling():
186186
Workforce("CB Test - Invalid", callbacks=[object()])
187187

188188

189-
def assert_event_sequence(events: list[WorkforceEvent], min_worker_count: int):
189+
def assert_event_sequence(
190+
events: list[type[WorkforceEvent]], min_worker_count: int
191+
):
190192
"""
191193
Validate that the given event sequence follows the expected logical order.
192194
This version is flexible to handle:
@@ -223,17 +225,11 @@ def assert_event_sequence(events: list[WorkforceEvent], min_worker_count: int):
223225

224226
# 4. Count all event types in the remaining events
225227
all_events = events[idx:]
226-
task_assigned_count = sum(
227-
isinstance(e, TaskAssignedEvent) for e in all_events
228-
)
229-
task_started_count = sum(
230-
isinstance(e, TaskStartedEvent) for e in all_events
231-
)
232-
task_completed_count = sum(
233-
isinstance(e, TaskCompletedEvent) for e in all_events
234-
)
228+
task_assigned_count = sum(e is TaskAssignedEvent for e in all_events)
229+
task_started_count = sum(e is TaskStartedEvent for e in all_events)
230+
task_completed_count = sum(e is TaskCompletedEvent for e in all_events)
235231
all_tasks_completed_count = sum(
236-
isinstance(e, AllTasksCompletedEvent) for e in all_events
232+
e is AllTasksCompletedEvent for e in all_events
237233
)
238234

239235
# 5. Validate basic invariants

0 commit comments

Comments
 (0)