Fix files and events replicators

CHANGELOG.md

@@ -18,6 +18,11 @@ Changes are grouped as follows
 
 ## [Unreleased]
 
+## [0.8.2] - 2020-11-11
+
+## Fixed
+- Fix broken behavior: add arg to copy functions of events and files replicators (code was broken as a result of the addition of a 7th arg to the invoking replication.thread function)
+
 ## [0.8.1] - 2020-07-06
 
 ## Fixed
@@ -157,4 +162,4 @@ and no exclusion of final datapoint
 ### Fixed
 - Time series replication no longer attempts to create security category-protected time series
 - Use pre-commit hooks to run black and unit tests
-- Send logs to google cloud stackdriver if configured, needed the right dependencies.
+- Send logs to google cloud stackdriver if configured, needed the right dependencies

cognite/replicator/_version.py

@@ -1 +1 @@
-__version__ = "0.8.1"
+__version__ = "0.8.2"

cognite/replicator/events.py

@@ -79,6 +79,7 @@ def copy_events(
     project_src: str,
     runtime: int,
     client: CogniteClient,
+    dst_ts = None, 
 ):
     """
     Creates/updates event objects and then attempts to create and update these objects in the destination.
@@ -90,6 +91,7 @@ def copy_events(
         project_src: The name of the project the object is being replicated from.
         runtime: The timestamp to be used in the new replicated metadata.
         client: The client corresponding to the destination project.
+        dst_ts: Is None for events, is called from replication's thread() fn for timeseries.
 
     """
     logging.debug(f"Starting to replicate {len(src_events)} events.")

cognite/replicator/files.py

@@ -72,6 +72,7 @@ def copy_files(
     project_src: str,
     runtime: int,
     client: CogniteClient,
+    dst_ts = None,
 ):
     """
     Creates/updates file objects and then attempts to create and update these objects in the destination.
@@ -83,6 +84,7 @@ def copy_files(
         project_src: The name of the project the object is being replicated from.
         runtime: The timestamp to be used in the new replicated metadata.
         client: The client corresponding to the destination project.
+        dst_ts: Is None for events, is called from replication's thread() fn for timeseries.
 
     """
     logging.debug(f"Starting to replicate {len(src_files)} files.")

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "cognite_replicator"
-version = "0.8.1"
+version = "0.8.2"
 description = "Python package for replicating data across CDF tenants. Copyright 2019 Cognite AS"
 license = "Apache-2.0"
 authors = [