engine.py 文件源码

def run_pipeline():
    pipeline = Pipeline(
        'example1',
        [
            GenerateFile,
            HashFile,
            RemoveFile,
        ]
    )
    coloredlogs.install(logging.DEBUG)
    for x in range(300):
        gevent.spawn(pipeline.backend.enqueue_job, Job.new(dict(job_type='generate-file')))

    pipeline.loop()