use that new new

PrefectHQ · Feb 11, 2025 · a2180c7 · a2180c7
1 parent 784096e
commit a2180c7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/prefect/client/orchestration/__init__.py b/src/prefect/client/orchestration/__init__.py
@@ -130,7 +130,7 @@
     PREFECT_SERVER_ALLOW_EPHEMERAL_MODE,
     PREFECT_TESTING_UNIT_TEST_MODE,
 )
-from prefect.types._datetime import DateTime
+from prefect.types._datetime import now
 
 if TYPE_CHECKING:
     from prefect.tasks import Task as TaskObject
@@ -608,7 +608,7 @@ async def get_runs_in_work_queue(
             List[FlowRun]: a list of FlowRun objects read from the queue
         """
         if scheduled_before is None:
-            scheduled_before = DateTime.now("UTC")
+            scheduled_before = now("UTC")
 
         try:
             response = await self._client.post(