Memory

flowtask.storages.tasks.memory

MemoryTaskStorage

MemoryTaskStorage(*args, **kwargs)

Bases: AbstractTaskStorage

Executing Task from Memory.

open_task async

open_task(payload=None, task=None, program=None, **kwargs)

open_task. Open A Task from Memory.