-record(workflow_definition, {
    name :: binary(),
    input_codec :: aion@codec:codec(any()),
    output_codec :: aion@codec:codec(any()),
    error_codec :: aion@codec:codec(any()),
    entry_fn :: fun((any()) -> {ok, any()} | {error, any()})
}).