def METHOD_NAME(self) -> None:
    row = GroupAssigneeRow.from_bulk(
        {
            "project_id": "2",
            "group_id": "1359",
            "date_added": "2019-09-19 00:17:55+00",
            "user_id": "1",
            "team_id": "",
        }
    )
    write_processed_messages(
        self.storage, [InsertBatch([row.to_clickhouse()], None)]
    )
    ret = (
        self.storage.get_cluster()
        .get_query_connection(ClickhouseClientSettings.QUERY)
        .execute("SELECT * FROM groupassignee_local;")
        .results
    )
    assert ret[0] == (
        0,  # offset
        0,  # deleted
        2,  # project_id
        1359,  # group_id
        datetime(2019, 9, 19, 0, 17, 55),
        1,  # user_id
        None,  # team_id
    )