Телеграмм чат группы python

если в задачах очереди asyncio.Queue закрывается таск .task_done() только в случае успешного выполнения, то когда где-то в процессе вылетит исключение и до .task_done() в итоге не дойдет, то очередь забьется нафиг и все полетит к чертям?

Я правильно себе это представляю?

источник

07:23пожаловаться #7

Rawan Qurmet in Python KZ

как и везде, не?

источник

07:33пожаловаться #8

Alex in Python KZ

Ответ понял, спасибо)))

источник

07:33пожаловаться #9

Alex in Python KZ

Я маленький и зелёный питонистик, я не знаю как везде))))

источник

07:34пожаловаться #10

Rawan Qurmet in Python KZ

task_done() идет в связке с get(), если не получилось обработать эту запись, то тут торг: удалить эту запись в исключении, либо держать в очереди, когда не починится скрипт

try:
    удали из очереди, т.к. я уже обработал
except Exeption as err:
    удали из очереди, даже если я не обработал или ничего не удаляй, я скоро починю

источник

07:35пожаловаться #11

Reffi_4 in Python KZ

Ну, оно валью еррор кинет же

источник

07:36пожаловаться #12

Reffi_4 in Python KZ

Если ты сам не обработаешь это никак

источник

07:37пожаловаться #13

Reffi_4 in Python KZ

источник

07:38пожаловаться #14

Alex in Python KZ

У меня исключения обрабатываются в глубине (преувеличено сказано), в случае успеха возвращаются данные для записи в бд, в случае не успеха просто False

И, грубо говоря, я сейчас сделал примерно так:

def some_task(queue):
.....
if result:
to_db()
queue.task_done()

источник

07:40пожаловаться #15

Alex in Python KZ

Эт норм?)

источник

07:43пожаловаться #16

Reffi_4 in Python KZ