Skip to content

Enable reducer in ensemble functions #17

Description

@kaizu
jobs = ((1, 'spam'), (2, 'ham'), (3, 'eggs'))
target = lambda args, job_id, task_id: (args[1] * args[0])
run_serial(target, jobs)  # => [['spam'], ['hamham'], ['eggseggseggs']]
reducer = lambda x, y: x + len(y)
run_serial(target, jobs, reducer=reducer, initializer=0)  # => [22]

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions