количество используемых слотов в воздушном потоке превышает лимит - PullRequest
Новая
       7

количество используемых слотов в воздушном потоке превышает лимит

0 голосов
/ 12 октября 2018

Есть три задачи «Сенсор» и один и тот же пул, для пула limit_sensor установлено значение 1, но ограничение пула не работает, три пула работают вместе 

sensor_wait = SqlSensor(
    task_id='sensor_wait',
    dag=dag,
    conn_id='dest_data',
    sql="select count(*) from test",
    poke_interval=10,
    timeout=60,
    pool='limit_sensor',
    priority_weight=100
)

same_pool1 = SqlSensor(
    task_id='same_pool1',
    dag=dag,
    conn_id='dest_data',
    sql="select count(*) from test",
    poke_interval=10,
    timeout=60,
    pool='limit_sensor',
    priority_weight=10
)

same_pool2 = SqlSensor(
    task_id='same_pool2',
    dag=dag,
    conn_id='dest_data',
    sql="select count(*) from test",
    poke_interval=10,
    timeout=60,
    pool='limit_sensor',
    priority_weight=10
)

есть журнал обратной засыпки, поток воздуха1.10.0 

[2018-10-12 11:20:35,036] {jobs.py:2198} INFO - [backfill progress] | finished run 0 of 1 | tasks waiting: 0 | succeeded: 0 | running: 3 | failed: 0 | skipped: 0 | deadlocked: 0 | not ready: 0

в веб-интерфейсе Admin->Pools вы можете увидеть: 

Pool    Slots    Used Slots    Queued Slots
limit_sensor    1    3    0

как мне сделать, чтобы лимит пула работал?спасибо.

...