dag_generator.results.pickle_result

PickleResult Objects

class PickleResult(BaseResult)

Processes the result of a task stored in a bit sequence in a file

write_df

def write_df(obj: Any, context: dict)

Write the Data Frame to the file storage. Sends a call to write

Arguments:

• obj: Dataset for writing
• context: context

write

def write(obj: Any, context: dict)

Write an object to file storage.

Arguments:

• obj: Object for writing
• context: context

read_df

def read_df(context: dict)

Read DataFrame from file storage. Sends a call to work.read

Arguments:

• context: context

read

def read(context: dict) -> Any

Read object from file storage.

Arguments:

• context: context

Returns:

DataFrame