🎯 feat: update trace module.

Author: korawica

src/ddeutil/workflow/audits.py

@@ -60,7 +60,7 @@
 
 from .__types import DictData
 from .conf import dynamic
-from .traces import Trace, get_trace, set_logging
+from .traces import Trace, get_trace
 
 logger = logging.getLogger("ddeutil.workflow")
 
@@ -129,7 +129,6 @@ class BaseAudit(BaseModel, ABC):
     """
 
     type: Literal["base"] = "base"
-    logging_name: str = "ddeutil.workflow"
     extras: DictData = Field(
         default_factory=dict,
         description="An extras parameter that want to override core config",
@@ -152,9 +151,6 @@ def __model_action(self) -> Self:
         """
         if dynamic("enable_write_audit", extras=self.extras):
             self.do_before()
-
-        # NOTE: Start setting log config in this line with cache.
-        set_logging(self.logging_name)
         return self
 
     @abstractmethod

src/ddeutil/workflow/conf.py

@@ -101,7 +101,8 @@ def registry_filter(self) -> list[str]:
         """Register Filter that is a list of importable string for the filter
         template.
 
-        :rtype: list[str]
+        Returns:
+            list[str]: A list of module import string.
         """
         regis_filter_str: str = env(
             "CORE_REGISTRY_FILTER", "ddeutil.workflow.templates"
@@ -130,17 +131,6 @@ def log_tz(self) -> ZoneInfo:
         """
         return ZoneInfo(env("LOG_TIMEZONE", "UTC"))
 
-    @property
-    def log_format(self) -> str:
-        return env(
-            "LOG_FORMAT",
-            (
-                "%(asctime)s.%(msecs)03d (%(process)-5d, "
-                "%(thread)-5d) [%(levelname)-7s] (%(cut_id)s) %(message)-120s "
-                "(%(filename)s:%(lineno)s) (%(name)-10s)"
-            ),
-        )
-
     @property
     def audit_conf(self) -> dict[str, Any]:
         return json.loads(
@@ -151,10 +141,6 @@ def audit_conf(self) -> dict[str, Any]:
     def enable_write_audit(self) -> bool:
         return str2bool(env("LOG_AUDIT_ENABLE_WRITE", "false"))
 
-    @property
-    def log_datetime_format(self) -> str:
-        return env("LOG_DATETIME_FORMAT", "%Y-%m-%d %H:%M:%S")
-
     @property
     def stage_default_id(self) -> bool:
         return str2bool(env("CORE_STAGE_DEFAULT_ID", "false"))
@@ -441,7 +427,8 @@ def type(self) -> str:
         """Return object of string type which implement on any registry. The
         object type.
 
-        :rtype: str
+        Returns:
+            str: A type that get from config data.
         """
         if _typ := self.data.get("type"):
             return _typ

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