%global _empty_manifest_terminate_build 0 Name: python-async-task-queue Version: 0.1.2 Release: 1 Summary: In-memory FIFO queue for concurrent task execution License: BSD-3-Clause URL: https://github.com/NarrativeScience/async-task-queue Source0: https://mirrors.nju.edu.cn/pypi/web/packages/f7/83/b419adb62ed208a6cf48f9c4a200e331549746b6fc4cc0831a1059aac145/async-task-queue-0.1.2.tar.gz BuildArch: noarch %description # async-task-queue [![CircleCI](https://circleci.com/gh/NarrativeScience/async-task-queue/tree/master.svg?style=shield)](https://circleci.com/gh/NarrativeScience/async-task-queue/tree/master) [![](https://img.shields.io/pypi/v/async-task-queue.svg)](https://pypi.org/pypi/async-task-queue/) [![License](https://img.shields.io/badge/License-BSD%203--Clause-blue.svg)](https://opensource.org/licenses/BSD-3-Clause) In-memory FIFO queue for concurrent task execution. Used to execute tasks concurrently with optional control (via semaphore) over the max number of tasks running at the same time. Features: - Queue processing summary logging - Introspection of failed, retried, and succeeded tasks - Task retries (optional) - Task execution timeout (optional) - Queue processing with semaphore (optional) - Batch size control (optional) TOC: - [Installation](#installation) - [Guide](#guide) - [Development](#development) ## Installation async-task-queue requires Python 3.6 or above. ```bash pip install async-task-queue ``` ## Guide ```python import logging from async_task_queue import AsyncTask, AsyncTaskQueue # Initialize a logger logger = logging.getLogger("foo") # Initialize an AsyncTaskQueue where: # - At most 5 tasks are running concurrently # - Number of tasks executing concurrently should be limited by a semaphore # - Failed tasks should be retried (default behavior) # - Executing the tasks queued should timeout and be cancelled after 5 minutes task_queue = AsyncTaskQueue( logger, use_semaphore=True, batch_size=5, execution_timeout=300 ) # Add async tasks to the queue task_queue.enqueue( [ AsyncTask(some_coroutine, *args, **kwargs) for args, kwargs in some_args_kwargs ] ) # Start processing the queue await task_queue.execute() ``` ## Development To develop async-task-queue, install dependencies and enable the pre-commit hook: ```bash pip install pre-commit tox pre-commit install ``` To run tests: ```bash tox ``` %package -n python3-async-task-queue Summary: In-memory FIFO queue for concurrent task execution Provides: python-async-task-queue BuildRequires: python3-devel BuildRequires: python3-setuptools BuildRequires: python3-pip %description -n python3-async-task-queue # async-task-queue [![CircleCI](https://circleci.com/gh/NarrativeScience/async-task-queue/tree/master.svg?style=shield)](https://circleci.com/gh/NarrativeScience/async-task-queue/tree/master) [![](https://img.shields.io/pypi/v/async-task-queue.svg)](https://pypi.org/pypi/async-task-queue/) [![License](https://img.shields.io/badge/License-BSD%203--Clause-blue.svg)](https://opensource.org/licenses/BSD-3-Clause) In-memory FIFO queue for concurrent task execution. Used to execute tasks concurrently with optional control (via semaphore) over the max number of tasks running at the same time. Features: - Queue processing summary logging - Introspection of failed, retried, and succeeded tasks - Task retries (optional) - Task execution timeout (optional) - Queue processing with semaphore (optional) - Batch size control (optional) TOC: - [Installation](#installation) - [Guide](#guide) - [Development](#development) ## Installation async-task-queue requires Python 3.6 or above. ```bash pip install async-task-queue ``` ## Guide ```python import logging from async_task_queue import AsyncTask, AsyncTaskQueue # Initialize a logger logger = logging.getLogger("foo") # Initialize an AsyncTaskQueue where: # - At most 5 tasks are running concurrently # - Number of tasks executing concurrently should be limited by a semaphore # - Failed tasks should be retried (default behavior) # - Executing the tasks queued should timeout and be cancelled after 5 minutes task_queue = AsyncTaskQueue( logger, use_semaphore=True, batch_size=5, execution_timeout=300 ) # Add async tasks to the queue task_queue.enqueue( [ AsyncTask(some_coroutine, *args, **kwargs) for args, kwargs in some_args_kwargs ] ) # Start processing the queue await task_queue.execute() ``` ## Development To develop async-task-queue, install dependencies and enable the pre-commit hook: ```bash pip install pre-commit tox pre-commit install ``` To run tests: ```bash tox ``` %package help Summary: Development documents and examples for async-task-queue Provides: python3-async-task-queue-doc %description help # async-task-queue [![CircleCI](https://circleci.com/gh/NarrativeScience/async-task-queue/tree/master.svg?style=shield)](https://circleci.com/gh/NarrativeScience/async-task-queue/tree/master) [![](https://img.shields.io/pypi/v/async-task-queue.svg)](https://pypi.org/pypi/async-task-queue/) [![License](https://img.shields.io/badge/License-BSD%203--Clause-blue.svg)](https://opensource.org/licenses/BSD-3-Clause) In-memory FIFO queue for concurrent task execution. Used to execute tasks concurrently with optional control (via semaphore) over the max number of tasks running at the same time. Features: - Queue processing summary logging - Introspection of failed, retried, and succeeded tasks - Task retries (optional) - Task execution timeout (optional) - Queue processing with semaphore (optional) - Batch size control (optional) TOC: - [Installation](#installation) - [Guide](#guide) - [Development](#development) ## Installation async-task-queue requires Python 3.6 or above. ```bash pip install async-task-queue ``` ## Guide ```python import logging from async_task_queue import AsyncTask, AsyncTaskQueue # Initialize a logger logger = logging.getLogger("foo") # Initialize an AsyncTaskQueue where: # - At most 5 tasks are running concurrently # - Number of tasks executing concurrently should be limited by a semaphore # - Failed tasks should be retried (default behavior) # - Executing the tasks queued should timeout and be cancelled after 5 minutes task_queue = AsyncTaskQueue( logger, use_semaphore=True, batch_size=5, execution_timeout=300 ) # Add async tasks to the queue task_queue.enqueue( [ AsyncTask(some_coroutine, *args, **kwargs) for args, kwargs in some_args_kwargs ] ) # Start processing the queue await task_queue.execute() ``` ## Development To develop async-task-queue, install dependencies and enable the pre-commit hook: ```bash pip install pre-commit tox pre-commit install ``` To run tests: ```bash tox ``` %prep %autosetup -n async-task-queue-0.1.2 %build %py3_build %install %py3_install install -d -m755 %{buildroot}/%{_pkgdocdir} if [ -d doc ]; then cp -arf doc %{buildroot}/%{_pkgdocdir}; fi if [ -d docs ]; then cp -arf docs %{buildroot}/%{_pkgdocdir}; fi if [ -d example ]; then cp -arf example %{buildroot}/%{_pkgdocdir}; fi if [ -d examples ]; then cp -arf examples %{buildroot}/%{_pkgdocdir}; fi pushd %{buildroot} if [ -d usr/lib ]; then find usr/lib -type f -printf "/%h/%f\n" >> filelist.lst fi if [ -d usr/lib64 ]; then find usr/lib64 -type f -printf "/%h/%f\n" >> filelist.lst fi if [ -d usr/bin ]; then find usr/bin -type f -printf "/%h/%f\n" >> filelist.lst fi if [ -d usr/sbin ]; then find usr/sbin -type f -printf "/%h/%f\n" >> filelist.lst fi touch doclist.lst if [ -d usr/share/man ]; then find usr/share/man -type f -printf "/%h/%f.gz\n" >> doclist.lst fi popd mv %{buildroot}/filelist.lst . mv %{buildroot}/doclist.lst . %files -n python3-async-task-queue -f filelist.lst %dir %{python3_sitelib}/* %files help -f doclist.lst %{_docdir}/* %changelog * Wed May 10 2023 Python_Bot - 0.1.2-1 - Package Spec generated