diff options
| author | Alex Grönholm <alex.gronholm@nextday.fi> | 2022-01-02 17:20:26 +0200 |
|---|---|---|
| committer | Alex Grönholm <alex.gronholm@nextday.fi> | 2022-02-15 02:20:18 +0200 |
| commit | fcd6d13a0d8fffe2169124eecfcda752fe07ec96 (patch) | |
| tree | 44bdb220015d3d489e367839f0f97328a029cdc5 /tests/test_schedulers.py | |
| parent | 82f6f8e230252efc19d0e5a38e218ac1c34563b8 (diff) | |
| download | apscheduler-fcd6d13a0d8fffe2169124eecfcda752fe07ec96.tar.gz | |
Fixed mypy errors in tests
Diffstat (limited to 'tests/test_schedulers.py')
| -rw-r--r-- | tests/test_schedulers.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/tests/test_schedulers.py b/tests/test_schedulers.py index 7657cec..4a1cc4e 100644 --- a/tests/test_schedulers.py +++ b/tests/test_schedulers.py @@ -102,6 +102,8 @@ class TestAsyncScheduler: ]) async def test_jitter(self, mocker: MockerFixture, timezone: ZoneInfo, max_jitter: float, expected_upper_bound: float) -> None: + job_id: UUID | None = None + def job_added_listener(event: Event) -> None: nonlocal job_id assert isinstance(event, JobAdded) @@ -115,7 +117,6 @@ class TestAsyncScheduler: async with AsyncScheduler(start_worker=False) as scheduler: trigger = IntervalTrigger(seconds=3, start_time=orig_start_time) job_added_event = anyio.Event() - job_id: UUID | None = None scheduler.events.subscribe(job_added_listener, {JobAdded}) schedule_id = await scheduler.add_schedule(dummy_async_job, trigger, max_jitter=max_jitter) @@ -248,6 +249,8 @@ class TestSyncScheduler: ]) def test_jitter(self, mocker: MockerFixture, timezone: ZoneInfo, max_jitter: float, expected_upper_bound: float) -> None: + job_id: UUID | None = None + def job_added_listener(event: Event) -> None: nonlocal job_id assert isinstance(event, JobAdded) @@ -261,7 +264,6 @@ class TestSyncScheduler: with Scheduler(start_worker=False) as scheduler: trigger = IntervalTrigger(seconds=3, start_time=orig_start_time) job_added_event = threading.Event() - job_id: UUID | None = None scheduler.events.subscribe(job_added_listener, {JobAdded}) schedule_id = scheduler.add_schedule(dummy_async_job, trigger, max_jitter=max_jitter) schedule = scheduler.get_schedule(schedule_id) |