[DOP-28176] Give worker access to transfer and group names (#308)

* [DOP-28176] syncmster-datatrentgen integration

* [DOP-28176] Gave worker access to transfer and group names

---------

Co-authored-by: Marat Akhmetov <ahmetovmr@mts.ru>

Author: marashka

docs/changelog/next_release/308.feature.rst

@@ -0,0 +1 @@
+Gave worker access to transfer and group names

syncmaster/dto/runs.py

@@ -6,5 +6,5 @@
 
 @dataclass
 class RunDTO:
-    id: str
+    id: int
     created_at: datetime

syncmaster/dto/transfers.py

@@ -14,11 +14,13 @@
 @dataclass
 class TransferDTO:
     type: ClassVar[str]
+    id: int
+    name: str
+    group_name: str
 
 
 @dataclass
 class DBTransferDTO(TransferDTO):
-    id: int
     table_name: str
     strategy: FullStrategy | IncrementalStrategy
     resources: Resources
@@ -33,7 +35,6 @@ def __post_init__(self):
 
 @dataclass
 class FileTransferDTO(TransferDTO):
-    id: int
     directory_path: str
     file_format: CSV | JSONLine | JSON | Excel | XML | ORC | Parquet
     strategy: FullStrategy | IncrementalStrategy

syncmaster/worker/controller.py

@@ -193,6 +193,8 @@ def __init__(
             connection_data=source_connection.data,
             run_data={"id": run.id, "created_at": run.created_at},
             transfer_id=run.transfer.id,
+            transfer_name=run.transfer.name,
+            group_name=run.transfer.group.name,
             transfer_params=run.transfer.source_params,
             strategy_params=run.transfer.strategy_params,
             resources=run.transfer.resources,
@@ -204,6 +206,8 @@ def __init__(
             connection_data=target_connection.data,
             run_data={"id": run.id, "created_at": run.created_at},
             transfer_id=run.transfer.id,
+            transfer_name=run.transfer.name,
+            group_name=run.transfer.group.name,
             transfer_params=run.transfer.target_params,
             strategy_params=run.transfer.strategy_params,
             resources=run.transfer.resources,
@@ -243,6 +247,8 @@ def get_handler(
         connection_auth_data: dict,
         run_data: dict[str, Any],
         transfer_id: int,
+        transfer_name: str,
+        group_name: str,
         transfer_params: dict[str, Any],
         strategy_params: dict[str, Any],
         resources: dict[str, Any],
@@ -262,6 +268,8 @@ def get_handler(
             connection_dto=connection_dto(**connection_data),
             transfer_dto=transfer_dto(
                 id=transfer_id,
+                name=transfer_name,
+                group_name=group_name,
                 strategy=Strategy.from_dict(strategy_params),
                 resources=Resources(**resources),
                 transformations=transformations,