def METHOD_NAME(
    self, setup_state: None, payload: SpanEvent, expected_result: Dict[str, Any]
) -> None:
    meta = KafkaMessageMetadata(
        offset=1, partition=2, timestamp=datetime.datetime(1970, 1, 1)
    )
    assert payload
    processed_rows = SpansMessageProcessor().process_message(payload, meta)
    assert isinstance(processed_rows, InsertBatch), processed_rows
    actual_result = processed_rows.rows[0]
    assert compare_types_and_values(actual_result, expected_result)