Fix broken run_notebooks GH action

examples/run_notebook.py

@@ -201,7 +201,7 @@ def extract_credential(credential_prefix: str) -> str:
 
         # A flow has been successfully published if it makes at least one successful workflow run since start_time,
         flow_runs = [flow.fetch(flow_run_dict["run_id"]) for flow_run_dict in flow.list_runs()]
-        flow_runs = [flow_run for flow_run in flow_runs if float(flow_run._created_at) > start_time]
+        flow_runs = [flow_run for flow_run in flow_runs if flow_run.created_at() > start_time]
         if len(flow_runs) == 0:
             continue
 

sdk/aqueduct/flow_run.py

@@ -1,5 +1,6 @@
 import textwrap
 import uuid
+from datetime import datetime
 from typing import Optional
 
 from aqueduct.artifacts import (
@@ -63,6 +64,14 @@ def status(self) -> ExecutionStatus:
         """Returns the status of the flow run."""
         return self._dag_result_resp.result.exec_state.status
 
+    def _created_at(self) -> datetime:
+        """Returns the datetime at which the flow run was created."""
+        return self._dag_result_resp.dag_created_at
+
+    def created_at(self) -> float:
+        """Returns the unix timestamp at which the flow run was created."""
+        return self._created_at().timestamp()
+
     def describe(self) -> None:
         """Prints out a human-readable description of the flow run."""
         url = generate_ui_url(
@@ -76,7 +85,7 @@ def describe(self) -> None:
                 f"""
             {format_header_for_print(f"'{self._dag.metadata.name}' Run")}
             ID: {self._id}
-            Created At (UTC): {self._dag_result_resp.dag_created_at.strftime(TIME_FORMAT)}
+            Created At (UTC): {self._created_at().strftime(TIME_FORMAT)}
             Status: {str(self.status())}
             UI: {url}
             """