blob: 2397c29ecedac2535dc14a0caf3a138114d87f21 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
from __future__ import annotations
from uuid import uuid4
from apscheduler import JobOutcome, JobReleased
from apscheduler.abc import Serializer
def test_serialize_job_released(serializer: Serializer) -> None:
event = JobReleased(
job_id=uuid4(), worker_id="test_worker", outcome=JobOutcome.success
)
payload = serializer.serialize(event.marshal(serializer))
event2 = JobReleased.unmarshal(serializer, serializer.deserialize(payload))
assert event == event2
|
