Test createdBefore run filter (#10270)

dagster-io · Nov 2, 2022 · c8dee2d · c8dee2d
1 parent 4df6e55
commit c8dee2d
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/python_modules/dagster/dagster_tests/core_tests/storage_tests/utils/run_storage.py b/python_modules/dagster/dagster_tests/core_tests/storage_tests/utils/run_storage.py
@@ -332,6 +332,9 @@ def test_add_run_tags(self, storage):
         }
 
     def test_fetch_by_filter(self, storage):
+
+        now = pendulum.now()
+
         assert storage
         one = make_new_run_id()
         two = make_new_run_id()
@@ -473,6 +476,12 @@ def test_fetch_by_filter(self, storage):
         assert len(some_runs) == 4
         assert count == 4
 
+        old_runs = storage.get_runs(RunsFilter(created_before=now.add(days=-1)))
+        assert len(old_runs) == 0
+
+        new_runs = storage.get_runs(RunsFilter(created_before=now.add(days=1)))
+        assert len(new_runs) == 4
+
     def test_fetch_count_by_tag(self, storage):
         assert storage
         one = make_new_run_id()