app.py 文件源码

def initialize_imagery(id, source_path):
    return chain(
        place_file.si(id, source_path),
        create_metadata.si(id),
        chord([create_overviews.si(id), create_warped_vrt.si(id)],
              chain(
                update_metadata.si(id),
                cleanup_ingestion.si(id),
              )
        ),
    )