Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
jamiedemaria committed Aug 19, 2024
1 parent 030d12d commit f74c004
Showing 1 changed file with 7 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@
from dagster._daemon.daemon import SensorDaemon
from dagster._daemon.types import DaemonHeartbeat
from dagster._serdes import serialize_pp
from dagster._time import create_datetime
from dagster._time import create_datetime, datetime_from_timestamp

win_py36 = _seven.IS_WINDOWS and sys.version_info[0] == 3 and sys.version_info[1] == 6

Expand Down Expand Up @@ -1395,14 +1395,18 @@ def test_backfill_created_time_filtering(self, storage: RunStorage):
all_backfills.append(backfill)

created_before = storage.get_backfills(
filters=BulkActionsFilter(created_before=all_backfills[3].backfill_timestamp)
filters=BulkActionsFilter(
created_before=datetime_from_timestamp(all_backfills[3].backfill_timestamp)
)
)
assert len(created_before) == 2
for backfill in created_before:
assert backfill.backfill_timestamp < all_backfills[3].backfill_timestamp

created_after = storage.get_backfills(
filters=BulkActionsFilter(created_after=all_backfills[3].backfill_timestamp)
filters=BulkActionsFilter(
created_after=datetime_from_timestamp(all_backfills[3].backfill_timestamp)
)
)
assert len(created_after) == 2
for backfill in created_after:
Expand Down

0 comments on commit f74c004

Please sign in to comment.