inkreach-prefect/prefect.yaml

prefect-version: 3.7.8
name: inkreach-prefect
pull:
- prefect.deployments.steps.git_clone:
    repository: https://oauth2:{{ prefect.blocks.secret.gitea-token }}@gitea.inkreach.cc/inkreachhub/inkreach-prefect.git
    branch: main
deployments:
- name: riin-order-sync
  entrypoint: flows/riin/order_sync.py:riin_order_sync
  work_pool:
    name: inkreach-pool
- name: riin-incremental-sync
  entrypoint: flows/riin/incremental_sync.py:riin_incremental_sync
  schedules:
  - cron: 0 * * * *
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: riin-recent-sync
  entrypoint: flows/riin/recent_sync.py:riin_recent_sync
  schedules:
  - cron: 30 * * * *
    timezone: Asia/Shanghai
    active: false  # 暂停:每小时重拉近7天全部订单商品,对 RIIN distribution/order/goods 调用量过大(增量/刷新未完结/日报核验已覆盖)
  work_pool:
    name: inkreach-pool
- name: riin-refresh-pending
  entrypoint: flows/riin/refresh_pending.py:riin_refresh_pending
  schedules:
  - cron: 0 */3 * * *
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: riin-by-orders-sync
  entrypoint: flows/riin/by_orders.py:riin_by_orders_sync
  work_pool:
    name: inkreach-pool
- name: riin-verify
  entrypoint: flows/riin/verify.py:riin_verify
  schedules:
  - cron: 0 6 * * *
    timezone: Asia/Shanghai
    active: false  # 暂停:与 daily-report 18:30 的核验子流程重复,保留日报一处即可
  work_pool:
    name: inkreach-pool
- name: sds-order-sync
  entrypoint: flows/sds/order_sync.py:sds_order_sync
  work_pool:
    name: inkreach-pool
- name: sds-incremental-sync
  entrypoint: flows/sds/incremental_sync.py:sds_incremental_sync
  schedules:
  - cron: 15 * * * *
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: sds-recent-sync
  entrypoint: flows/sds/recent_sync.py:sds_recent_sync
  schedules:
  - cron: 45 * * * *
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: sds-refresh-pending
  entrypoint: flows/sds/refresh_pending.py:sds_refresh_pending
  schedules:
  - cron: 0 */2 * * *
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: sds-refresh-100-prefix
  entrypoint: flows/sds/refresh_100_prefix.py:sds_refresh_100_prefix
  schedules:
  - cron: 30 */2 * * *
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: sds-verify
  entrypoint: flows/sds/verify.py:sds_verify
  schedules:
  - cron: 0 7 * * *
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: platform-order-riin
  entrypoint: flows/platform_order/riin.py:riin_platform_sync
  schedules:
  - cron:  '*/30 * * * *'
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: platform-order-rouhui
  entrypoint: flows/platform_order/rouhui.py:rouhui_platform_sync
  schedules:
  - cron: '*/15 * * * *'
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: platform-order-sdspod
  entrypoint: flows/platform_order/sdspod.py:sdspod_platform_sync
  schedules:
  - cron: 0 * * * *
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: platform-order-upper-sync
  entrypoint: flows/platform_order/platform_order_upper_sync.py:platform_order_upper_sync
  schedules:
  - cron: '*/2 * * * *'
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: shop-dim-sync
  entrypoint: flows/platform_order/sync_shop_dim.py:shop_dim_sync
  schedules:
  - cron: '*/5 * * * *'
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: label-ocr
  entrypoint: flows/label_ocr.py:label_ocr
  schedules:
  - cron: 0 * * * *
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: wecom-alert
  entrypoint: flows/monitor/alert_failure.py:wecom_alert_failure
  triggers:
  - type: event
    enabled: true
    match:
      prefect.resource.id: prefect.flow-run.*
    expect:
    - prefect.flow-run.Failed
    - prefect.flow-run.Crashed
    parameters:
      event: "{{ event }}"
  work_pool:
    name: inkreach-pool
- name: daily-report
  entrypoint: flows/monitor/daily_report.py:daily_report
  schedules:
  - cron: 30 18 * * *
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool
- name: device-check
  entrypoint: flows/monitor/device_check.py:device_check
  schedules:
  - cron: 0 9 * * *
    timezone: Asia/Shanghai
  work_pool:
    name: inkreach-pool