🎯 feat: update trace module.

Author: korawica

src/ddeutil/workflow/job.py

@@ -865,34 +865,14 @@ def get_outputs(
         else:
             return output.get("jobs", {}).get(_id, {})
 
-    def execute(
+    def _execute(
         self,
         params: DictData,
-        *,
-        run_id: StrOrNone = None,
+        run_id: str,
+        parent_run_id: Optional[str] = None,
         event: Optional[Event] = None,
     ) -> Result:
-        """Job execution with passing dynamic parameters from the workflow
-        execution. It will generate matrix values at the first step and run
-        multithread on this metrics to the `stages` field of this job.
-
-            This method be execution routing for call dynamic execution function
-        with specific target `runs-on` value.
-
-        Args
-            params: (DictData) A parameter context that also pass from the
-                workflow execute method.
-            run_id: (str) An execution running ID.
-            event: (Event) An Event manager instance that use to cancel this
-                execution if it forces stopped by parent execution.
-
-        Returns
-            Result: Return Result object that create from execution context.
-        """
-        ts: float = time.monotonic()
-        parent_run_id, run_id = extract_id(
-            (self.id or "EMPTY"), run_id=run_id, extras=self.extras
-        )
+        """"""
         trace: Trace = get_trace(
             run_id, parent_run_id=parent_run_id, extras=self.extras
         )
@@ -908,7 +888,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
@@ -919,14 +899,14 @@ def execute(
                 params,
                 run_id=parent_run_id,
                 event=event,
-            ).make_info({"execution_time": time.monotonic() - ts})
+            )
         elif self.runs_on.type == DOCKER:  # pragma: no cov
             return docker_execution(
                 self,
                 params,
                 run_id=parent_run_id,
                 event=event,
-            ).make_info({"execution_time": time.monotonic() - ts})
+            )
         elif self.runs_on.type == CONTAINER:  # pragma: no cov
             from .plugins.providers.container import container_execute
 
@@ -935,7 +915,7 @@ def execute(
                 params,
                 run_id=parent_run_id,
                 event=event,
-            ).make_info({"execution_time": time.monotonic() - ts})
+            )
         elif self.runs_on.type == AWS_BATCH:  # pragma: no cov
             from .plugins.providers.aws import aws_batch_execute
 
@@ -944,7 +924,7 @@ def execute(
                 params,
                 run_id=parent_run_id,
                 event=event,
-            ).make_info({"execution_time": time.monotonic() - ts})
+            )
         elif self.runs_on.type == GCP_BATCH:  # pragma: no cov
             from .plugins.providers.gcs import gcp_batch_execute
 
@@ -953,7 +933,7 @@ def execute(
                 params,
                 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} "
@@ -970,10 +950,51 @@ def execute(
                     f"not support yet."
                 ).to_dict(),
             },
-            info={"execution_time": time.monotonic() - ts},
             extras=self.extras,
         )
 
+    def execute(
+        self,
+        params: DictData,
+        *,
+        run_id: StrOrNone = None,
+        event: Optional[Event] = None,
+    ) -> Result:
+        """Job execution with passing dynamic parameters from the workflow
+        execution. It will generate matrix values at the first step and run
+        multithread on this metrics to the `stages` field of this job.
+
+            This method be execution routing for call dynamic execution function
+        with specific target `runs-on` value.
+
+        Args
+            params: (DictData) A parameter context that also pass from the
+                workflow execute method.
+            run_id: (str) An execution running ID.
+            event: (Event) An Event manager instance that use to cancel this
+                execution if it forces stopped by parent execution.
+
+        Returns
+            Result: Return Result object that create from execution context.
+        """
+        ts: float = time.monotonic()
+        parent_run_id, run_id = extract_id(
+            (self.id or "EMPTY"), run_id=run_id, extras=self.extras
+        )
+        trace: Trace = get_trace(
+            run_id, parent_run_id=parent_run_id, extras=self.extras
+        )
+        trace.info(f"[JOB]: Handler {self.id or 'EMPTY'}")
+        result_caught: Result = self._execute(
+            params,
+            run_id=run_id,
+            parent_run_id=parent_run_id,
+            event=event,
+        )
+        return result_caught.make_info(
+            {"execution_time": time.monotonic() - ts}
+        )
+
 
 def mark_errors(context: DictData, error: JobError) -> None:
     """Make the errors context result with the refs value depends on the nested