File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -371,7 +371,7 @@ def pause_unpause_example(ctx):
371371
372372 # checking if this queue it is paused (spoiler: it's not)
373373 is_paused = ctx.exec.is_paused(
374- " test"
374+ queue = " test"
375375 )
376376 print (" Is paused" , is_paused)
377377 time.sleep(2 )
@@ -381,12 +381,12 @@ def pause_unpause_example(ctx):
381381
382382 # pausing this queue (this job it's and others active jobs will be not affected but not new job will be start until queue is resumed)
383383 ctx.exec.pause(
384- " test"
384+ queue = " test"
385385 )
386386
387387 # checking again now is suposed to be paused
388388 is_paused = ctx.exec.is_paused(
389- " test"
389+ queue = " test"
390390 )
391391 print (" Is paused" , is_paused)
392392 time.sleep(2 )
@@ -395,12 +395,12 @@ def pause_unpause_example(ctx):
395395
396396 # resuming this queue (all other workers can process jobs again)
397397 ctx.exec.resume(
398- " test"
398+ queue = " test"
399399 )
400400
401401 # checking again and is suposed to be resumed
402402 is_paused = ctx.exec.is_paused(
403- " test"
403+ queue = " test"
404404 )
405405 print (" Is paused" , is_paused)
406406 time.sleep(2 )
Original file line number Diff line number Diff line change @@ -9,7 +9,7 @@ def pause_unpause_example(ctx):
99
1010 # checking if this queue it is paused (spoiler: it's not)
1111 is_paused = ctx .exec .is_paused (
12- "test"
12+ queue = "test"
1313 )
1414 print ("Is paused" , is_paused )
1515 time .sleep (2 )
@@ -19,12 +19,12 @@ def pause_unpause_example(ctx):
1919
2020 # pausing this queue (this job it's and others active jobs will be not affected but not new job will be start until queue is resumed)
2121 ctx .exec .pause (
22- "test"
22+ queue = "test"
2323 )
2424
2525 # checking again now is suposed to be paused
2626 is_paused = ctx .exec .is_paused (
27- "test"
27+ queue = "test"
2828 )
2929 print ("Is paused" , is_paused )
3030 time .sleep (2 )
@@ -33,12 +33,12 @@ def pause_unpause_example(ctx):
3333
3434 # resuming this queue (all other workers can process jobs again)
3535 ctx .exec .resume (
36- "test"
36+ queue = "test"
3737 )
3838
3939 # checking again and is suposed to be resumed
4040 is_paused = ctx .exec .is_paused (
41- "test"
41+ queue = "test"
4242 )
4343 print ("Is paused" , is_paused )
4444 time .sleep (2 )
Original file line number Diff line number Diff line change 11[project ]
22name = " omniq"
3- version = " 1.5.0 "
3+ version = " 1.5.1 "
44authors = [
55 { name =" Not Empty Foundation" , email =" dev@not-empty.org" },
66]
You can’t perform that action at this time.
0 commit comments