fix data_to_be_added

bobokvsky · bobokvsky · commit 0442e6f43f9d · 2023-07-24T14:05:57.000+03:00
diff --git a/datapipe_label_studio_lite/pipeline.py b/datapipe_label_studio_lite/pipeline.py
@@ -263,7 +263,7 @@ def upload_tasks(df: pd.DataFrame, idx: IndexDF):
             else:
                 df_res = df_to_be_uploaded
             logger.debug(
-                f"Deleted {len(df_existing_tasks_to_be_deleted)} tasks, uploaded {len(data_to_be_added)} tasks."
+                f"Deleted {len(df_existing_tasks_to_be_deleted)} tasks, uploaded {len(df_to_be_uploaded)} tasks."
             )
             return df_res[self.primary_keys + ["task_id"]]
 
diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "datapipe-label-studio-lite"
-version = "0.3.0-alpha.1"
+version = "0.3.0-alpha.2"
 description = ""
 authors = [
     "Alexander Kozlov <bobokvsky@epoch8.co>",

Original file line number	Diff line number	Diff line change
`@@ -263,7 +263,7 @@ def upload_tasks(df: pd.DataFrame, idx: IndexDF):`
`263`	`263`	`else:`
`264`	`264`	`df_res = df_to_be_uploaded`
`265`	`265`	`logger.debug(`
`266`		`- f"Deleted {len(df_existing_tasks_to_be_deleted)} tasks, uploaded {len(data_to_be_added)} tasks."`
	`266`	`+ f"Deleted {len(df_existing_tasks_to_be_deleted)} tasks, uploaded {len(df_to_be_uploaded)} tasks."`
`267`	`267`	`)`
`268`	`268`	`return df_res[self.primary_keys + ["task_id"]]`
`269`	`269`