Médéric Descazeaux
12/17/2020, 3:24 PMorchest.output({'df': df}, name="current")
And for "Process data":
orchest.output({'df': df,
'processedlist': processedlist,
'ignoredlist': ignoredlist,
'messageslist': messageslist},
name='processed')
I get the following error:
---------------------------------------------------------------------------
ValueError Traceback (most recent call last)
<ipython-input-3-b9a2b7cd25cd> in <module>
5 print("Getting current and pending logs from Orchest pipeline...", end=" ")
6
----> 7 data = orchest.get_inputs()
8
9 display(data)
/orchest/orchest-sdk/python/orchest/transfer.py in get_inputs(ignore_failure, verbose)
859 parent_uuid = parent.properties["uuid"]
860 get_output_method, args, kwargs, metadata = _resolve(
--> 861 parent_uuid, consumer=step_uuid
862 )
863
/orchest/orchest-sdk/python/orchest/transfer.py in _resolve(step_uuid, consumer)
753 method_info = method(step_uuid, consumer=consumer)
754 else:
--> 755 method_info = method(step_uuid)
756
757 except OutputNotFoundError:
/orchest/orchest-sdk/python/orchest/transfer.py in _resolve_disk(step_uuid)
349 with open(head_file, "r") as f:
350 timestamp, serialization, name = f.read().split(
--> 351 Config.__METADATA_SEPARATOR__
352 )
353
ValueError: not enough values to unpack (expected 3, got 1)
ValueError: not enough values to unpack (expected 3, got 1)
The error only happens if the "Load current logs" block is connected to the "Merge logs" one.Rick Lamers
Jacopo
12/17/2020, 3:31 PMMédéric Descazeaux
12/17/2020, 3:31 PMRick Lamers
Médéric Descazeaux
12/17/2020, 3:49 PMRick Lamers
orchest.output_to_disk(data, name=my_name)
from the step that outputs the data.Médéric Descazeaux
12/17/2020, 4:01 PMRick Lamers