🎯 feat: passing execution time info on the result.

Author: korawica

src/ddeutil/workflow/audits.py

@@ -20,10 +20,11 @@
     get_audit_model: Factory function for creating audit instances
 
 Example:
+
     ```python
     from ddeutil.workflow.audits import get_audit_model
 
-    # Create file-based audit
+    # NOTE: Create file-based Audit.
     audit = get_audit_model(run_id="run-123")
     audit.info("Workflow execution started")
     audit.success("Workflow completed successfully")

src/ddeutil/workflow/job.py

@@ -773,6 +773,7 @@ def execute(
         Returns
             Result: Return Result object that create from execution context.
         """
+        ts: float = time.monotonic()
         parent_run_id: str = run_id
         run_id: str = gen_id((self.id or "EMPTY"), unique=True)
         trace: Trace = get_trace(
@@ -790,7 +791,7 @@ def execute(
                 params,
                 run_id=parent_run_id,
                 event=event,
-            )
+            ).make_info({"execution_time": time.monotonic() - ts})
         elif self.runs_on.type == SELF_HOSTED:  # pragma: no cov
             pass
         elif self.runs_on.type == AZ_BATCH:  # pragma: no cov
@@ -802,7 +803,7 @@ def execute(
                 run_id=run_id,
                 parent_run_id=parent_run_id,
                 event=event,
-            )
+            ).make_info({"execution_time": time.monotonic() - ts})
 
         trace.error(
             f"[JOB]: Execution not support runs-on: {self.runs_on.type.value!r} "
@@ -819,6 +820,8 @@ def execute(
                     f"not support yet."
                 ).to_dict(),
             },
+            info={"execution_time": time.monotonic() - ts},
+            extras=self.extras,
         )
 
 
@@ -1010,6 +1013,7 @@ def local_execute(
 
     :rtype: Result
     """
+    ts: float = time.monotonic()
     parent_run_id: StrOrNone = run_id
     run_id: str = gen_id((job.id or "EMPTY"), unique=True)
     trace: Trace = get_trace(
@@ -1028,6 +1032,7 @@ def local_execute(
             parent_run_id=parent_run_id,
             status=SKIP,
             context=catch(context, status=SKIP),
+            info={"execution_time": time.monotonic() - ts},
             extras=job.extras,
         )
 
@@ -1056,6 +1061,7 @@ def local_execute(
                     ).to_dict()
                 },
             ),
+            info={"execution_time": time.monotonic() - ts},
             extras=job.extras,
         )
 
@@ -1127,6 +1133,7 @@ def local_execute(
         parent_run_id=parent_run_id,
         status=status,
         context=catch(context, status=status, updated=errors),
+        info={"execution_time": time.monotonic() - ts},
         extras=job.extras,
     )
 

src/ddeutil/workflow/workflow.py

@@ -460,7 +460,7 @@ def release(
                 context=context,
                 parent_run_id=parent_run_id,
                 run_id=run_id,
-                execution_time=99,
+                execution_time=rs.info.get("execution_time", 0),
                 extras=self.extras,
             ).save(excluded=excluded)
         )
@@ -656,6 +656,7 @@ def execute(
                 parent_run_id=parent_run_id,
                 status=SUCCESS,
                 context=catch(context, status=SUCCESS),
+                info={"execution_time": time.monotonic() - ts},
                 extras=self.extras,
             )
 
@@ -687,6 +688,7 @@ def execute(
                         ).to_dict(),
                     },
                 ),
+                info={"execution_time": time.monotonic() - ts},
                 extras=self.extras,
             )
 
@@ -729,6 +731,7 @@ def execute(
                                 ).to_dict(),
                             },
                         ),
+                        info={"execution_time": time.monotonic() - ts},
                         extras=self.extras,
                     )
                 elif check == SKIP:  # pragma: no cov
@@ -812,6 +815,7 @@ def execute(
                     parent_run_id=parent_run_id,
                     status=st,
                     context=catch(context, status=st),
+                    info={"execution_time": time.monotonic() - ts},
                     extras=self.extras,
                 )
 
@@ -840,6 +844,7 @@ def execute(
                     ).to_dict(),
                 },
             ),
+            info={"execution_time": time.monotonic() - ts},
             extras=self.extras,
         )