def METHOD_NAME(self) -> None:
    timestamp = datetime.now(timezone.utc)
    started = timestamp - timedelta(hours=1)
    payload = {
        "device_family": "iPhone12,3",
        "distinct_id": "b3ef3211-58a4-4b36-a9a1-5a55df0d9aaf",
        "duration": 1947.49,
        "environment": "production",
        "org_id": 1,
        "os": "iOS",
        "os_version": "13.3.1",
        "project_id": 42,
        "release": "sentry-test@1.0.0",
        "retention_days": 90,
        "seq": 42,
        "errors": 0,
        "session_id": "8333339f-5675-4f89-a9a0-1c935255ab58",
        "started": started.timestamp(),
        "status": "crashed",
        "received": timestamp.timestamp(),
    }
    meta = KafkaMessageMetadata(
        offset=1, partition=2, timestamp=datetime(1970, 1, 1)
    )
    assert SessionsProcessor().process_message(payload, meta) == InsertBatch(
        [
            {
                "distinct_id": "b3ef3211-58a4-4b36-a9a1-5a55df0d9aaf",
                "quantity": 1,
                "duration": 1947490,
                "environment": "production",
                "org_id": 1,
                "project_id": 42,
                "release": "sentry-test@1.0.0",
                "retention_days": 90,
                "seq": 42,
                # abnormal counts as at least one error
                "errors": 1,
                "session_id": "8333339f-5675-4f89-a9a0-1c935255ab58",
                "started": started.replace(tzinfo=None),
                "status": 2,
                "received": timestamp.replace(tzinfo=None),
            }
        ],
        None,
    )