From 1e70e2b6b7507666c5e81860cd8866e7360fb4ba Mon Sep 17 00:00:00 2001 From: JamieDeMaria Date: Tue, 20 Aug 2024 10:18:07 -0400 Subject: [PATCH] comment --- .../dagster/dagster/_core/execution/backfill.py | 15 +++++++++++++++ .../dagster_postgres_tests/test_run_storage.py | 1 - 2 files changed, 15 insertions(+), 1 deletion(-) diff --git a/python_modules/dagster/dagster/_core/execution/backfill.py b/python_modules/dagster/dagster/_core/execution/backfill.py index e74946ba2c8e9..e6d19be2610f6 100644 --- a/python_modules/dagster/dagster/_core/execution/backfill.py +++ b/python_modules/dagster/dagster/_core/execution/backfill.py @@ -42,6 +42,21 @@ def from_graphql_input(graphql_str): @record class BulkActionsFilter: + """Filters to use when querying for bulk actions (i.e. backfills) from the BulkActionsTable. + + Each field of the BulkActionsFilter represents a logical AND with each other. For + example, if you specify status and created_before, then you will receive only bulk actions + with the specified states AND the created before created_before. If left blank, then + all values will be permitted for that field. + + Args: + status (Optional[BulkActionStatus]): A status to filter by. + created_before (Optional[DateTime]): Filter by bulk actions that were created before this datetime. Note that the + create_time for each bulk action is stored in UTC. + created_after (Optional[DateTime]): Filter by bulk actions that were created after this datetime. Note that the + create_time for each bulk action is stored in UTC. + """ + status: Optional[BulkActionStatus] = None created_before: Optional[datetime] = None created_after: Optional[datetime] = None diff --git a/python_modules/libraries/dagster-postgres/dagster_postgres_tests/test_run_storage.py b/python_modules/libraries/dagster-postgres/dagster_postgres_tests/test_run_storage.py index fd389302832c1..153a17faeab64 100644 --- a/python_modules/libraries/dagster-postgres/dagster_postgres_tests/test_run_storage.py +++ b/python_modules/libraries/dagster-postgres/dagster_postgres_tests/test_run_storage.py @@ -8,7 +8,6 @@ class TestPostgresRunStorage(TestRunStorage): - # TestPostgresRunStorage::test_backfill_created_time_filtering __test__ = True @pytest.fixture(scope="function", name="storage")