def METHOD_NAME(self) -> Sequence[operations.SqlOperation]:
    return [
        operations.CreateTable(
            storage_set=StorageSetKey.EVENTS,
            table_name="errors_dist",
            columns=columns,
            engine=table_engines.Distributed(
                local_table_name="errors_local",
                sharding_key="event_hash",
            ),
        )
    ]