Returns the current queue size. Note that this doesn't count any tasks currently being processed by workers. :param broker: optional broker :return: current queue size :rtype: int
(broker=None)
| 423 | |
| 424 | |
| 425 | def queue_size(broker=None): |
| 426 | """ |
| 427 | Returns the current queue size. |
| 428 | Note that this doesn't count any tasks currently being processed by workers. |
| 429 | |
| 430 | :param broker: optional broker |
| 431 | :return: current queue size |
| 432 | :rtype: int |
| 433 | """ |
| 434 | if not broker: |
| 435 | broker = get_broker() |
| 436 | return broker.queue_size() |
| 437 | |
| 438 | |
| 439 | def async_iter(func, args_iter, **kwargs): |