Compare commits
No commits in common. "54327432fae98957576fc42f1f80c81cc39ad656" and "61ff43722fa1b2377712be2888a44585c8df9cbf" have entirely different histories.
54327432fa
...
61ff43722f
22
LICENSE
22
LICENSE
@ -1,22 +0,0 @@
|
|||||||
MIT License
|
|
||||||
|
|
||||||
Copyright (c) 2024 Sam Griesemer
|
|
||||||
|
|
||||||
Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
||||||
of this software and associated documentation files (the "Software"), to deal
|
|
||||||
in the Software without restriction, including without limitation the rights
|
|
||||||
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
||||||
copies of the Software, and to permit persons to whom the Software is
|
|
||||||
furnished to do so, subject to the following conditions:
|
|
||||||
|
|
||||||
The above copyright notice and this permission notice shall be included in all
|
|
||||||
copies or substantial portions of the Software.
|
|
||||||
|
|
||||||
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
||||||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
||||||
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
||||||
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
||||||
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
||||||
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
|
||||||
SOFTWARE.
|
|
||||||
|
|
@ -1,5 +1,5 @@
|
|||||||
# Overview
|
# Overview
|
||||||
`execlib` is a lightweight multi-threaded job framework written in Python. It implements a
|
`execlog` is a lightweight multi-threaded job framework written in Python. It implements a
|
||||||
simple event-based model over core Python utilities like `ThreadPoolExecutor` to
|
simple event-based model over core Python utilities like `ThreadPoolExecutor` to
|
||||||
facilitate reactivity and manage concurrent responses.
|
facilitate reactivity and manage concurrent responses.
|
||||||
|
|
||||||
|
@ -6,7 +6,7 @@
|
|||||||
# -- Project information -----------------------------------------------------
|
# -- Project information -----------------------------------------------------
|
||||||
# https://www.sphinx-doc.org/en/master/usage/configuration.html#project-information
|
# https://www.sphinx-doc.org/en/master/usage/configuration.html#project-information
|
||||||
|
|
||||||
project = 'execlib'
|
project = 'execlog'
|
||||||
copyright = '2024, Sam Griesemer'
|
copyright = '2024, Sam Griesemer'
|
||||||
author = 'Sam Griesemer'
|
author = 'Sam Griesemer'
|
||||||
|
|
||||||
|
@ -1,4 +1,4 @@
|
|||||||
# `execlib` package docs
|
# `execlog` package docs
|
||||||
{ref}`genindex`
|
{ref}`genindex`
|
||||||
{ref}`modindex`
|
{ref}`modindex`
|
||||||
{ref}`search`
|
{ref}`search`
|
||||||
@ -10,18 +10,18 @@
|
|||||||
:nosignatures:
|
:nosignatures:
|
||||||
:recursive:
|
:recursive:
|
||||||
|
|
||||||
execlib.Handler
|
execlog.Handler
|
||||||
execlib.Listener
|
execlog.Listener
|
||||||
execlib.Router
|
execlog.Router
|
||||||
execlib.Server
|
execlog.Server
|
||||||
execlib.listeners
|
execlog.listeners
|
||||||
```
|
```
|
||||||
|
|
||||||
## Auto-reference contents
|
## Auto-reference contents
|
||||||
```{toctree}
|
```{toctree}
|
||||||
:maxdepth: 3
|
:maxdepth: 3
|
||||||
|
|
||||||
_autoref/execlib.rst
|
_autoref/execlog.rst
|
||||||
```
|
```
|
||||||
|
|
||||||
```{toctree}
|
```{toctree}
|
||||||
|
@ -1,10 +0,0 @@
|
|||||||
from execlib import util
|
|
||||||
from execlib import routers
|
|
||||||
from execlib import syncers
|
|
||||||
from execlib import listeners
|
|
||||||
|
|
||||||
from execlib.server import Server
|
|
||||||
from execlib.handler import Handler
|
|
||||||
from execlib.listener import Listener
|
|
||||||
from execlib.event import Event, FileEvent
|
|
||||||
from execlib.router import Router, ChainRouter, Event, RouterBuilder, route
|
|
@ -1 +0,0 @@
|
|||||||
from execlib.listeners.path import PathListener
|
|
@ -1 +0,0 @@
|
|||||||
from execlib.routers.path import PathRouter
|
|
@ -1 +0,0 @@
|
|||||||
from execlib.syncers.router import PathDiffer, PathRouterSyncer
|
|
@ -1,2 +0,0 @@
|
|||||||
from execlib.util import path
|
|
||||||
from execlib.util import generic
|
|
10
execlog/__init__.py
Normal file
10
execlog/__init__.py
Normal file
@ -0,0 +1,10 @@
|
|||||||
|
from execlog import util
|
||||||
|
from execlog import routers
|
||||||
|
from execlog import syncers
|
||||||
|
from execlog import listeners
|
||||||
|
|
||||||
|
from execlog.server import Server
|
||||||
|
from execlog.handler import Handler
|
||||||
|
from execlog.listener import Listener
|
||||||
|
from execlog.event import Event, FileEvent
|
||||||
|
from execlog.router import Router, ChainRouter, Event, RouterBuilder, route
|
@ -5,7 +5,7 @@ See also:
|
|||||||
'''
|
'''
|
||||||
import threading
|
import threading
|
||||||
|
|
||||||
from execlib.event import Event
|
from execlog.event import Event
|
||||||
|
|
||||||
|
|
||||||
class Listener[E: Event](threading.Thread):
|
class Listener[E: Event](threading.Thread):
|
1
execlog/listeners/__init__.py
Normal file
1
execlog/listeners/__init__.py
Normal file
@ -0,0 +1 @@
|
|||||||
|
from execlog.listeners.path import PathListener
|
@ -8,10 +8,10 @@ from collections import defaultdict
|
|||||||
from colorama import Fore, Back, Style
|
from colorama import Fore, Back, Style
|
||||||
from inotify_simple import INotify, Event as iEvent, flags as iflags, masks as imasks
|
from inotify_simple import INotify, Event as iEvent, flags as iflags, masks as imasks
|
||||||
|
|
||||||
from execlib import util
|
from execlog import util
|
||||||
from execlib.util.generic import color_text
|
from execlog.util.generic import color_text
|
||||||
from execlib.event import FileEvent
|
from execlog.event import FileEvent
|
||||||
from execlib.listener import Listener
|
from execlog.listener import Listener
|
||||||
|
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
@ -18,9 +18,9 @@ from concurrent.futures import ThreadPoolExecutor, wait, as_completed
|
|||||||
|
|
||||||
from tqdm.auto import tqdm
|
from tqdm.auto import tqdm
|
||||||
|
|
||||||
from execlib.event import Event
|
from execlog.event import Event
|
||||||
from execlib.listener import Listener
|
from execlog.listener import Listener
|
||||||
from execlib.util.generic import color_text, get_func_name
|
from execlog.util.generic import color_text, get_func_name
|
||||||
|
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
1
execlog/routers/__init__.py
Normal file
1
execlog/routers/__init__.py
Normal file
@ -0,0 +1 @@
|
|||||||
|
from execlog.routers.path import PathRouter
|
@ -2,10 +2,10 @@ import logging
|
|||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
from typing import Callable
|
from typing import Callable
|
||||||
|
|
||||||
from execlib.router import Router
|
from execlog.router import Router
|
||||||
from execlib.event import FileEvent
|
from execlog.event import FileEvent
|
||||||
from execlib.util.path import glob_match
|
from execlog.util.path import glob_match
|
||||||
from execlib.listeners.path import PathListener
|
from execlog.listeners.path import PathListener
|
||||||
|
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
@ -26,8 +26,8 @@ from inotify_simple import flags
|
|||||||
from fastapi import FastAPI, WebSocket
|
from fastapi import FastAPI, WebSocket
|
||||||
from fastapi.staticfiles import StaticFiles
|
from fastapi.staticfiles import StaticFiles
|
||||||
|
|
||||||
from execlib.routers.path import PathRouter
|
from execlog.routers.path import PathRouter
|
||||||
from execlib.handler import Handler as LREndpoint
|
from execlog.handler import Handler as LREndpoint
|
||||||
|
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
1
execlog/syncers/__init__.py
Normal file
1
execlog/syncers/__init__.py
Normal file
@ -0,0 +1 @@
|
|||||||
|
from execlog.syncers.router import PathDiffer, PathRouterSyncer
|
@ -10,10 +10,10 @@ from inotify_simple import flags as iflags
|
|||||||
from co3.resources import DiskResource
|
from co3.resources import DiskResource
|
||||||
from co3 import Differ, Syncer, Database
|
from co3 import Differ, Syncer, Database
|
||||||
|
|
||||||
from execlib.event import Event
|
from execlog.event import Event
|
||||||
from execlib.router import CancelledFrameError
|
from execlog.router import CancelledFrameError
|
||||||
from execlib.routers import PathRouter
|
from execlog.routers import PathRouter
|
||||||
from execlib.util.generic import color_text
|
from execlog.util.generic import color_text
|
||||||
|
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
2
execlog/util/__init__.py
Normal file
2
execlog/util/__init__.py
Normal file
@ -0,0 +1,2 @@
|
|||||||
|
from execlog.util import path
|
||||||
|
from execlog.util import generic
|
@ -46,8 +46,8 @@ class ColorFormatter(logging.Formatter):
|
|||||||
formatter = self.FORMATS[submodule]
|
formatter = self.FORMATS[submodule]
|
||||||
|
|
||||||
name = record.name
|
name = record.name
|
||||||
if package == 'execlib':
|
if package == 'execlog':
|
||||||
name = f'execlib.{subsubmodule}'
|
name = f'execlog.{subsubmodule}'
|
||||||
|
|
||||||
limit = 26
|
limit = 26
|
||||||
name = name[:limit]
|
name = name[:limit]
|
@ -1,56 +1,25 @@
|
|||||||
[build-system]
|
[build-system]
|
||||||
requires = ["setuptools", "wheel", "setuptools-git-versioning>=2.0,<3"]
|
requires = ["setuptools"]
|
||||||
build-backend = "setuptools.build_meta"
|
build-backend = "setuptools.build_meta"
|
||||||
|
|
||||||
# populates dynamically set version with latest git tag
|
|
||||||
[tool.setuptools-git-versioning]
|
|
||||||
enabled = true
|
|
||||||
|
|
||||||
[project]
|
[project]
|
||||||
name = "execlib"
|
name = "execlog"
|
||||||
|
version = "0.4.1"
|
||||||
|
authors = [
|
||||||
|
{ name="Sam Griesemer", email="samgriesemer@gmail.com" },
|
||||||
|
]
|
||||||
description = "Lightweight multi-threaded job framework"
|
description = "Lightweight multi-threaded job framework"
|
||||||
readme = "README.md"
|
readme = "README.md"
|
||||||
requires-python = ">=3.12"
|
requires-python = ">=3.12"
|
||||||
dynamic = ["version"]
|
|
||||||
#license = {file = "LICENSE"}
|
|
||||||
authors = [
|
|
||||||
{ name="Sam Griesemer", email="samgriesemer+git@gmail.com" },
|
|
||||||
]
|
|
||||||
keywords = ["concurrent", "async", "inotify"]
|
|
||||||
classifiers = [
|
classifiers = [
|
||||||
"Programming Language :: Python :: 3.12",
|
"Programming Language :: Python :: 3",
|
||||||
"License :: OSI Approved :: MIT License",
|
"License :: OSI Approved :: MIT License",
|
||||||
"Operating System :: OS Independent",
|
"Operating System :: OS Independent",
|
||||||
"Development Status :: 3 - Alpha",
|
|
||||||
"Intended Audience :: Developers",
|
|
||||||
]
|
]
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"tqdm",
|
"tqdm"
|
||||||
"wcmatch",
|
|
||||||
"uvicorn",
|
|
||||||
"fastapi",
|
|
||||||
"colorama",
|
|
||||||
"starlette",
|
|
||||||
"inotify_simple",
|
|
||||||
]
|
]
|
||||||
|
|
||||||
[project.optional-dependencies]
|
|
||||||
tests = ["pytest", "websockets"]
|
|
||||||
docs = [
|
|
||||||
"sphinx",
|
|
||||||
"sphinx-togglebutton",
|
|
||||||
"sphinx-autodoc-typehints",
|
|
||||||
"furo",
|
|
||||||
"myst-parser",
|
|
||||||
]
|
|
||||||
|
|
||||||
[project.urls]
|
|
||||||
Homepage = "https://doc.olog.io/execlib"
|
|
||||||
Documentation = "https://doc.olog.io/execlib"
|
|
||||||
Repository = "https://git.olog.io/olog/execlib"
|
|
||||||
Issues = "https://git.olog.io/olog/execlib/issues"
|
|
||||||
|
|
||||||
|
|
||||||
[tool.setuptools.packages.find]
|
[tool.setuptools.packages.find]
|
||||||
include = ["execlib*"] # pattern to match package names
|
include = ["execlog*"] # pattern to match package names
|
||||||
|
|
||||||
|
21
requirements.txt
Normal file
21
requirements.txt
Normal file
@ -0,0 +1,21 @@
|
|||||||
|
# -- package-specific --
|
||||||
|
fastapi
|
||||||
|
starlette
|
||||||
|
uvicorn
|
||||||
|
inotify_simple
|
||||||
|
tqdm
|
||||||
|
wcmatch
|
||||||
|
websockets
|
||||||
|
|
||||||
|
# -- logging --
|
||||||
|
colorama
|
||||||
|
|
||||||
|
# -- sphinx docs --
|
||||||
|
sphinx
|
||||||
|
sphinx-togglebutton
|
||||||
|
furo
|
||||||
|
myst-parser
|
||||||
|
sphinx-autodoc-typehints
|
||||||
|
|
||||||
|
# -- testing ---
|
||||||
|
pytest
|
@ -3,10 +3,10 @@ import logging
|
|||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
from functools import partial
|
from functools import partial
|
||||||
|
|
||||||
from execlib import util
|
from execlog import util
|
||||||
from execlib import ChainRouter, Event
|
from execlog import ChainRouter, Event
|
||||||
from execlib.routers import PathRouter
|
from execlog.routers import PathRouter
|
||||||
from execlib.listeners import PathListener
|
from execlog.listeners import PathListener
|
||||||
|
|
||||||
|
|
||||||
logger = logging.getLogger()
|
logger = logging.getLogger()
|
||||||
|
@ -3,10 +3,10 @@ from pathlib import Path
|
|||||||
from functools import partial
|
from functools import partial
|
||||||
from concurrent.futures import wait
|
from concurrent.futures import wait
|
||||||
|
|
||||||
from execlib import util
|
from execlog import util
|
||||||
from execlib import ChainRouter, Event
|
from execlog import ChainRouter, Event
|
||||||
from execlib.routers import PathRouter
|
from execlog.routers import PathRouter
|
||||||
from execlib.listeners import PathListener
|
from execlog.listeners import PathListener
|
||||||
|
|
||||||
|
|
||||||
logger = logging.getLogger()
|
logger = logging.getLogger()
|
||||||
|
@ -4,8 +4,8 @@ import threading
|
|||||||
import logging
|
import logging
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
|
|
||||||
from execlib import Server
|
from execlog import Server
|
||||||
from execlib.routers import PathRouter
|
from execlog.routers import PathRouter
|
||||||
|
|
||||||
|
|
||||||
logger = logging.getLogger()
|
logger = logging.getLogger()
|
||||||
|
Loading…
Reference in New Issue
Block a user