Change jobDescription for DBReader & FileDFReader

MobileTeleSystems · Oct 30, 2024 · 9c72d7a · 9c72d7a
1 parent e1ab213
commit 9c72d7a
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/docs/changelog/next_release/+.improvement.1.rst b/docs/changelog/next_release/+.improvement.1.rst
@@ -0,0 +1 @@
+Change Spark ``jobDescription`` for DBReader & FileDFReader from ``DBReader.run() -> Connection`` to ``Connection -> DBReader.run()``.
diff --git a/onetl/db/db_reader/db_reader.py b/onetl/db/db_reader/db_reader.py
@@ -635,7 +635,7 @@ def run(self) -> DataFrame:
 
         self._check_strategy()
 
-        job_description = f"{self.__class__.__name__}.run({self.source}) -> {self.connection}"
+        job_description = f"{self.connection} -> {self.__class__.__name__}.run({self.source})"
         with override_job_description(self.connection.spark, job_description):
             if not self._connection_checked:
                 self._log_parameters()

diff --git a/onetl/file/file_df_reader/file_df_reader.py b/onetl/file/file_df_reader/file_df_reader.py
@@ -212,9 +212,9 @@ def run(self, files: Iterable[str | os.PathLike] | None = None) -> DataFrame:
             self._log_parameters(files)
 
         if files:
-            job_description = f"{self.__class__.__name__}.run([..files..]) -> {self.connection}"
+            job_description = f"{self.connection} -> {self.__class__.__name__}.run([..files..])"
         else:
-            job_description = f"{self.__class__.__name__}.run({self.source_path}) -> {self.connection}"
+            job_description = f"{self.connection} -> {self.__class__.__name__}.run({self.source_path})"
 
         with override_job_description(self.connection.spark, job_description):
             paths: FileSet[PurePathProtocol] = FileSet()