Removing prints from examples

examples/dask_example.py

@@ -55,16 +55,16 @@ def sum_list(values):
     print("Getting first task only:")
     task1 = Flowcept.db.query(filter={"task_id": t1.key})[0]
     assert task1["workflow_id"] == wf_id
-    print(task1)
+    # print(task1)
     print("\n\n")
     print("Getting all tasks from this workflow:")
     all_tasks = Flowcept.db.query(filter={"workflow_id": wf_id})
     assert len(all_tasks) == 4
     assert all(t.get("finished") is True for t in all_tasks)
     assert all_tasks[-1]["generated"]["arg0"] == 30, "Checking if the last result was saved."
-    print(all_tasks)
+    # print(all_tasks)
     print("\n\n")
     print("Getting workflow info:")
     wf_info = Flowcept.db.query(filter={"workflow_id": wf_id}, collection="workflows")[0]
     assert wf_info["workflow_id"] == wf_id
-    print(wf_info)
+    # print(wf_info)

examples/mlflow_example.py

@@ -35,4 +35,4 @@
     run_data = interceptor.dao.get_run_data(run_id)
     task = Flowcept.db.query(filter={"task_id": run.info.run_uuid})[0]
     assert task["status"] == "FINISHED"
-    print(task)
+    # print(task)

examples/simple_instrumented_script.py

@@ -16,4 +16,6 @@ def mult_two(n):
     o1 = sum_one(n)
     o2 = mult_two(o1)
     print(o2)
-print(Flowcept.db.query(filter={"workflow_id": Flowcept.current_workflow_id}))
+docs = Flowcept.db.query(filter={"workflow_id": Flowcept.current_workflow_id})
+print(len(docs))
+

examples/tensorboard_example.py

@@ -137,4 +137,4 @@ def reset_tensorboard_dir(logdir, watch_interval_sec):
 
     tasks = Flowcept.db.query(filter={"workflow_id": wf_id})
     assert len(tasks) == 16
-    print(tasks)
+    print(len(tasks))