ataskq
| Name | ataskq JSON |
| Version |
0.5.1
JSON |
| download | |
| home_page | None |
| Summary | An in process task queue for distributed computing systems. |
| upload_time | 2024-04-21 07:23:29 |
| maintainer | None |
| docs_url | None |
| author | None |
| requires_python | >=3.8 |
| license | None |
| keywords | python task queue distributed systems distributed computing |
| VCS |  |
| bugtrack_url | |
| requirements | annotated-types anyio attrs black certifi cfgv charset-normalizer click distlib elastic-transport elasticsearch exceptiongroup fastapi filelock h11 identify idna importlib-metadata iniconfig multipledispatch mypy-extensions nodeenv packaging pathspec Pillow platformdirs pluggy pre-commit psycopg2-binary py pycodestyle pydantic pydantic_core pyparsing pytest python-multipart PyYAML requests sniffio starlette tomli typing_extensions urllib3 uvicorn virtualenv zipp |
| Travis-CI | No Travis. |
| coveralls test coverage | No coveralls. |
# a-task-queue
An in process task queue for distributed computing systems.
## Usage
```python
from ataskq import TaskQ, Task, targs
# create job
tr = TaskQ().create_job()
# add tasks
# entrypoint stands for the relevant function import statement
# (here we use build in demo functions)
tr.add_tasks([
Task(entrypoint='ataskq.tasks_utils.hello_world'),
Task(entrypoint='ataskq.tasks_utils.dummy_args_task', targs=targs(
'arg0', 'arg1', kwarg1=10, kwarg2='this is kwarg2')),
])
# run the tasks
tr.run() # to run in parallel add num_processes=N
```
more example can be found [here](./examples)
## Contributer
setup project git hooks
```
contrib/setup.sh
```
### vs code
to get nominal vscode settings run
```
./contrib/.vscode/init.sh
```
Raw data
{
"_id": null,
"home_page": null,
"name": "ataskq",
"maintainer": null,
"docs_url": null,
"requires_python": ">=3.8",
"maintainer_email": null,
"keywords": "python, task, queue, distributed systems, distributed computing",
"author": null,
"author_email": null,
"download_url": "https://files.pythonhosted.org/packages/f2/c8/54cc4ed874ec379bffa91ea8252f4f548c39fbc365d0c6cbb5cc9b69a544/ataskq-0.5.1.tar.gz",
"platform": null,
"description": "# a-task-queue\nAn in process task queue for distributed computing systems.\n\n## Usage\n```python\nfrom ataskq import TaskQ, Task, targs\n\n# create job\ntr = TaskQ().create_job()\n\n# add tasks\n# entrypoint stands for the relevant function import statement\n# (here we use build in demo functions)\ntr.add_tasks([\n Task(entrypoint='ataskq.tasks_utils.hello_world'),\n Task(entrypoint='ataskq.tasks_utils.dummy_args_task', targs=targs(\n 'arg0', 'arg1', kwarg1=10, kwarg2='this is kwarg2')),\n])\n\n# run the tasks\ntr.run() # to run in parallel add num_processes=N\n```\n\nmore example can be found [here](./examples)\n\n## Contributer\nsetup project git hooks\n```\ncontrib/setup.sh\n```\n\n### vs code\nto get nominal vscode settings run\n```\n./contrib/.vscode/init.sh\n```\n",
"bugtrack_url": null,
"license": null,
"summary": "An in process task queue for distributed computing systems.",
"version": "0.5.1",
"project_urls": {
"Homepage": "https://github.com/innoviz-swt/a-task-queue",
"Issues": "https://github.com/innoviz-swt/a-task-queue/issues"
},
"split_keywords": [
"python",
" task",
" queue",
" distributed systems",
" distributed computing"
],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "e5045a006d6cab34efcc230d22308f35a9fdada2ef100787d3a70a211eadebbd",
"md5": "848db26ccecaccb3522b2e9c1bfe8a1f",
"sha256": "5c27fb094882561cf8764b01140a2d74fa6ebdbbcbbd81c9cae9d5a111c7e7ae"
},
"downloads": -1,
"filename": "ataskq-0.5.1-py3-none-any.whl",
"has_sig": false,
"md5_digest": "848db26ccecaccb3522b2e9c1bfe8a1f",
"packagetype": "bdist_wheel",
"python_version": "py3",
"requires_python": ">=3.8",
"size": 68932,
"upload_time": "2024-04-21T07:23:28",
"upload_time_iso_8601": "2024-04-21T07:23:28.479445Z",
"url": "https://files.pythonhosted.org/packages/e5/04/5a006d6cab34efcc230d22308f35a9fdada2ef100787d3a70a211eadebbd/ataskq-0.5.1-py3-none-any.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"blake2b_256": "f2c854cc4ed874ec379bffa91ea8252f4f548c39fbc365d0c6cbb5cc9b69a544",
"md5": "65b6002253b6a963583eae16fb42487a",
"sha256": "e5dd2841244a40284e347bd739d080e0b371615d415362ac0c73bca741a78fc5"
},
"downloads": -1,
"filename": "ataskq-0.5.1.tar.gz",
"has_sig": false,
"md5_digest": "65b6002253b6a963583eae16fb42487a",
"packagetype": "sdist",
"python_version": "source",
"requires_python": ">=3.8",
"size": 59265,
"upload_time": "2024-04-21T07:23:29",
"upload_time_iso_8601": "2024-04-21T07:23:29.990258Z",
"url": "https://files.pythonhosted.org/packages/f2/c8/54cc4ed874ec379bffa91ea8252f4f548c39fbc365d0c6cbb5cc9b69a544/ataskq-0.5.1.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2024-04-21 07:23:29",
"github": true,
"gitlab": false,
"bitbucket": false,
"codeberg": false,
"github_user": "innoviz-swt",
"github_project": "a-task-queue",
"travis_ci": false,
"coveralls": false,
"github_actions": true,
"requirements": [
{
"name": "annotated-types",
"specs": [
[
"==",
"0.6.0"
]
]
},
{
"name": "anyio",
"specs": [
[
"==",
"3.7.1"
]
]
},
{
"name": "attrs",
"specs": [
[
"==",
"22.2.0"
]
]
},
{
"name": "black",
"specs": [
[
"==",
"24.2.0"
]
]
},
{
"name": "certifi",
"specs": [
[
"==",
"2023.11.17"
]
]
},
{
"name": "cfgv",
"specs": [
[
"==",
"3.4.0"
]
]
},
{
"name": "charset-normalizer",
"specs": [
[
"==",
"3.3.2"
]
]
},
{
"name": "click",
"specs": [
[
"==",
"8.1.7"
]
]
},
{
"name": "distlib",
"specs": [
[
"==",
"0.3.7"
]
]
},
{
"name": "elastic-transport",
"specs": [
[
"==",
"8.11.0"
]
]
},
{
"name": "elasticsearch",
"specs": [
[
"==",
"8.11.1"
]
]
},
{
"name": "exceptiongroup",
"specs": [
[
"==",
"1.2.0"
]
]
},
{
"name": "fastapi",
"specs": [
[
"==",
"0.104.1"
]
]
},
{
"name": "filelock",
"specs": [
[
"==",
"3.13.1"
]
]
},
{
"name": "h11",
"specs": [
[
"==",
"0.14.0"
]
]
},
{
"name": "identify",
"specs": [
[
"==",
"2.5.31"
]
]
},
{
"name": "idna",
"specs": [
[
"==",
"3.6"
]
]
},
{
"name": "importlib-metadata",
"specs": [
[
"==",
"4.8.3"
]
]
},
{
"name": "iniconfig",
"specs": [
[
"==",
"1.1.1"
]
]
},
{
"name": "multipledispatch",
"specs": [
[
"==",
"1.0.0"
]
]
},
{
"name": "mypy-extensions",
"specs": [
[
"==",
"1.0.0"
]
]
},
{
"name": "nodeenv",
"specs": [
[
"==",
"1.8.0"
]
]
},
{
"name": "packaging",
"specs": [
[
"==",
"23.2"
]
]
},
{
"name": "pathspec",
"specs": [
[
"==",
"0.12.1"
]
]
},
{
"name": "Pillow",
"specs": [
[
"==",
"10.1.0"
]
]
},
{
"name": "platformdirs",
"specs": [
[
"==",
"3.11.0"
]
]
},
{
"name": "pluggy",
"specs": [
[
"==",
"1.0.0"
]
]
},
{
"name": "pre-commit",
"specs": [
[
"==",
"3.5.0"
]
]
},
{
"name": "psycopg2-binary",
"specs": [
[
"==",
"2.9.9"
]
]
},
{
"name": "py",
"specs": [
[
"==",
"1.11.0"
]
]
},
{
"name": "pycodestyle",
"specs": [
[
"==",
"2.11.1"
]
]
},
{
"name": "pydantic",
"specs": [
[
"==",
"2.5.2"
]
]
},
{
"name": "pydantic_core",
"specs": [
[
"==",
"2.14.5"
]
]
},
{
"name": "pyparsing",
"specs": [
[
"==",
"3.0.7"
]
]
},
{
"name": "pytest",
"specs": [
[
"==",
"7.0.1"
]
]
},
{
"name": "python-multipart",
"specs": [
[
"==",
"0.0.6"
]
]
},
{
"name": "PyYAML",
"specs": [
[
"==",
"6.0.1"
]
]
},
{
"name": "requests",
"specs": [
[
"==",
"2.31.0"
]
]
},
{
"name": "sniffio",
"specs": [
[
"==",
"1.3.0"
]
]
},
{
"name": "starlette",
"specs": [
[
"==",
"0.27.0"
]
]
},
{
"name": "tomli",
"specs": [
[
"==",
"1.2.3"
]
]
},
{
"name": "typing_extensions",
"specs": [
[
"==",
"4.9.0"
]
]
},
{
"name": "urllib3",
"specs": [
[
"==",
"2.1.0"
]
]
},
{
"name": "uvicorn",
"specs": [
[
"==",
"0.24.0.post1"
]
]
},
{
"name": "virtualenv",
"specs": [
[
"==",
"20.24.6"
]
]
},
{
"name": "zipp",
"specs": [
[
"==",
"3.6.0"
]
]
}
],
"lcname": "ataskq"
}
