Update dependency protobuf to v4.25.2 - abandoned

cognite/replicator/assets.py

@@ -46,9 +46,11 @@ def build_asset_create(
         metadata=replication.new_metadata(src_asset, project_src, runtime),
         source=src_asset.source,
         parent_id=src_id_dst_map[src_asset.parent_id] if depth > 0 else None,
-        data_set_id=datasets.replicate(src_client, dst_client, src_asset.data_set_id, src_dst_dataset_mapping)
-        if config and config.get("dataset_support", False)
-        else None,
+        data_set_id=(
+            datasets.replicate(src_client, dst_client, src_asset.data_set_id, src_dst_dataset_mapping)
+            if config and config.get("dataset_support", False)
+            else None
+        ),
     )
 
 

cognite/replicator/events.py

@@ -41,19 +41,23 @@ def create_event(
 
     return Event(
         external_id=src_event.external_id,
-        start_time=src_event.start_time
-        if src_event.start_time and src_event.end_time and src_event.start_time < src_event.end_time
-        else src_event.end_time,
+        start_time=(
+            src_event.start_time
+            if src_event.start_time and src_event.end_time and src_event.start_time < src_event.end_time
+            else src_event.end_time
+        ),
         end_time=src_event.end_time,
         type=src_event.type,
         subtype=src_event.subtype,
         description=src_event.description,
         metadata=replication.new_metadata(src_event, project_src, runtime),
         asset_ids=replication.get_asset_ids(src_event.asset_ids, src_dst_ids_assets),
         source=src_event.source,
-        data_set_id=datasets.replicate(src_client, dst_client, src_event.data_set_id, src_dst_dataset_mapping)
-        if config and config.get("dataset_support", False)
-        else None,
+        data_set_id=(
+            datasets.replicate(src_client, dst_client, src_event.data_set_id, src_dst_dataset_mapping)
+            if config and config.get("dataset_support", False)
+            else None
+        ),
     )
 
 
@@ -101,9 +105,11 @@ def update_event(
     dst_event.asset_ids = replication.get_asset_ids(src_event.asset_ids, src_dst_ids_assets)
     dst_event.source = src_event.source
     dst_event.data_set_id = (
-        datasets.replicate(src_client, dst_client, src_event.data_set_id, src_dst_dataset_mapping)
-        if config and config.get("dataset_support", False)
-        else None,
+        (
+            datasets.replicate(src_client, dst_client, src_event.data_set_id, src_dst_dataset_mapping)
+            if config and config.get("dataset_support", False)
+            else None
+        ),
     )
     return dst_event
 

cognite/replicator/files.py

@@ -48,9 +48,11 @@ def create_file(
         mime_type=mime_type,
         metadata=replication.new_metadata(src_file, project_src, runtime),
         asset_ids=replication.get_asset_ids(src_file.asset_ids, src_dst_ids_assets),
-        data_set_id=datasets.replicate(src_client, dst_client, src_file.data_set_id, src_dst_dataset_mapping)
-        if config and config.get("dataset_support", False)
-        else None,
+        data_set_id=(
+            datasets.replicate(src_client, dst_client, src_file.data_set_id, src_dst_dataset_mapping)
+            if config and config.get("dataset_support", False)
+            else None
+        ),
     )
 
 
@@ -91,9 +93,11 @@ def update_file(
     dst_file.source_created_time = src_file.source_created_time
     dst_file.source_modified_time = src_file.source_modified_time
     dst_file.data_set_id = (
-        datasets.replicate(src_client, dst_client, src_file.data_set_id, src_dst_dataset_mapping)
-        if config and config.get("dataset_support", False)
-        else None,
+        (
+            datasets.replicate(src_client, dst_client, src_file.data_set_id, src_dst_dataset_mapping)
+            if config and config.get("dataset_support", False)
+            else None
+        ),
     )
     return dst_file
 

cognite/replicator/relationships.py

@@ -41,16 +41,20 @@ def create_relationship(
         target_external_id=src_relationship.target_external_id,
         target_type=src_relationship.target_type,
         target=src_relationship.target,
-        start_time=src_relationship.start_time
-        if src_relationship.start_time
-        and src_relationship.end_time
-        and src_relationship.start_time < src_relationship.end_time
-        else src_relationship.end_time,
+        start_time=(
+            src_relationship.start_time
+            if src_relationship.start_time
+            and src_relationship.end_time
+            and src_relationship.start_time < src_relationship.end_time
+            else src_relationship.end_time
+        ),
         end_time=src_relationship.end_time,
         confidence=src_relationship.confidence,
-        data_set_id=datasets.replicate(src_client, dst_client, src_relationship.data_set_id, src_dst_dataset_mapping)
-        if config and config.get("dataset_support", False)
-        else None,
+        data_set_id=(
+            datasets.replicate(src_client, dst_client, src_relationship.data_set_id, src_dst_dataset_mapping)
+            if config and config.get("dataset_support", False)
+            else None
+        ),
     )
 
 
@@ -97,9 +101,11 @@ def update_relationship(
     dst_relationship.end_time = src_relationship.end_time
     dst_relationship.confidence = src_relationship.confidence
     dst_relationship.data_set_id = (
-        datasets.replicate(src_client, dst_client, src_relationship.data_set_id, src_dst_dataset_mapping)
-        if config and config.get("dataset_support", False)
-        else None,
+        (
+            datasets.replicate(src_client, dst_client, src_relationship.data_set_id, src_dst_dataset_mapping)
+            if config and config.get("dataset_support", False)
+            else None
+        ),
     )
     return dst_relationship
 

cognite/replicator/sequences.py

@@ -51,9 +51,11 @@ def create_sequence(
             external_id=src_seq.external_id,
             metadata=replication.new_metadata(src_seq, project_src, runtime),
             columns=src_seq.columns,
-            data_set_id=datasets.replicate(src_client, dst_client, src_seq.data_set_id, src_dst_dataset_mapping)
-            if config and config.get("dataset_support", False)
-            else None,
+            data_set_id=(
+                datasets.replicate(src_client, dst_client, src_seq.data_set_id, src_dst_dataset_mapping)
+                if config and config.get("dataset_support", False)
+                else None
+            ),
         )
     else:
         return Sequence(
@@ -62,9 +64,11 @@ def create_sequence(
             external_id=src_seq.external_id,
             metadata=replication.new_metadata(src_seq, project_src, runtime),
             columns=src_seq.columns,
-            data_set_id=datasets.replicate(src_client, dst_client, src_seq.data_set_id, src_dst_dataset_mapping)
-            if config and config.get("dataset_support", False)
-            else None,
+            data_set_id=(
+                datasets.replicate(src_client, dst_client, src_seq.data_set_id, src_dst_dataset_mapping)
+                if config and config.get("dataset_support", False)
+                else None
+            ),
         )
 
 
@@ -107,9 +111,11 @@ def update_sequence(
     dst_seq.external_id = src_seq.external_id
     dst_seq.metadata = replication.new_metadata(src_seq, project_src, runtime)
     dst_seq.data_set_id = (
-        datasets.replicate(src_client, dst_client, src_seq.data_set_id, src_dst_dataset_mapping)
-        if config and config.get("dataset_support", False)
-        else None,
+        (
+            datasets.replicate(src_client, dst_client, src_seq.data_set_id, src_dst_dataset_mapping)
+            if config and config.get("dataset_support", False)
+            else None
+        ),
     )
     return dst_seq
 

cognite/replicator/time_series.py

@@ -50,9 +50,11 @@ def create_time_series(
         description=src_ts.description,
         security_categories=src_ts.security_categories,
         legacy_name=src_ts.external_id,
-        data_set_id=datasets.replicate(src_client, dst_client, src_ts.data_set_id, src_dst_dataset_mapping)
-        if config and config.get("dataset_support", False)
-        else None,
+        data_set_id=(
+            datasets.replicate(src_client, dst_client, src_ts.data_set_id, src_dst_dataset_mapping)
+            if config and config.get("dataset_support", False)
+            else None
+        ),
     )