def METHOD_NAME(self) -> Sequence[operations.SqlOperation]:
    return [
        operations.CreateTable(
            storage_set=StorageSetKey.OUTCOMES,
            table_name="outcomes_raw_dist",
            columns=raw_columns,
            engine=table_engines.Distributed(
                local_table_name="outcomes_raw_local",
                sharding_key="org_id",
            ),
        ),
        operations.CreateTable(
            storage_set=StorageSetKey.OUTCOMES,
            table_name="outcomes_hourly_dist",
            columns=hourly_columns,
            engine=table_engines.Distributed(
                local_table_name="outcomes_hourly_local",
                sharding_key="org_id",
            ),
        ),
    ]