Refactor workflow for Python package upload and remove deprecated test workflow; update README for Python 3.10 compatibility and adjust project metadata

Author: abhijeetkaze

.github/workflows/publish.yml

@@ -1,26 +1,39 @@
-name: publish
+# This workflow will upload a Python Package using Twine when a release is created
+# For more information see: https://docs.github.com/en/actions/automating-builds-and-tests/building-and-testing-python#publishing-to-package-registries
+
+# This workflow uses actions that are not certified by GitHub.
+# They are provided by a third-party and are governed by
+# separate terms of service, privacy policy, and support
+# documentation.
+
+name: Upload Python Package
 
 on:
   release:
-    types: [published]     # publish full release to PyPI when a release is created on Github
-  workflow_dispatch:
+    types: [published]
+  workflow_dispatch:  # allow manual triggering
 
 permissions:
-  contents: write
   id-token: write
 
 jobs:
-  publish_to_pypi:
-    if: github.event_name == 'release' || github.event_name == 'workflow_dispatch'
+  deploy:
     runs-on: ubuntu-latest
+
     steps:
       - uses: actions/checkout@v4
-      - uses: astral-sh/setup-uv@v6
+      - name: Set up Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: "3.x"
+      - name: Install dependencies
+        run: |
+          python -m pip install --upgrade pip
+          pip install build hatch
+      - name: Build package
+        run: python -m build
+      - name: Publish package
+        uses: pypa/gh-action-pypi-publish@release/v1
         with:
-          enable-cache: true
-          activate-environment: true
-      - run: uv sync
-      - run: uv run ruff check --no-fix --select PLE # quick check for syntax errors to avoid waiting time doing the rest of the build
-      - run: uv build
-      - run: uv run pytest tests                  # dont push the package to PyPI if the tests fail
-      - run: uv publish --trusted-publishing always
+          user: __token__
+          password: ${{ secrets.PYPI_API_TOKEN }}

.github/workflows/test.yaml .github/workflows/test.yaml.disabled.github/workflows/test.yaml renamed to .github/workflows/test.yaml.disabled

@@ -1 +1 @@
-3.12
+3.10

.python-version

@@ -6,6 +6,26 @@ It's designed for quickly building event-driven applications with Python in a wa
 
 It provides a [pydantic](https://docs.pydantic.dev/latest/)-based API for implementing publish-subscribe patterns with type safety, async/sync handler support, and advanced features like event forwarding between buses. It's inspired by the simplicity of `JS`'s async system and DOM events APIs, and it aims to bring a fully type-checked [`EventTarget`](https://developer.mozilla.org/en-US/docs/Web/API/EventTarget)-style API to Python.
 
+## ⚠️ Note
+
+**This is a modified version of [bubus](https://github.com/abhijeetkaze/bubus) to support Python 3.10.**
+
+[![PyPI version](https://img.shields.io/pypi/v/bubus-py310x)](https://pypi.org/project/bubus-py310x/)
+[![Python Versions](https://img.shields.io/pypi/pyversions/bubus-py310x)](https://pypi.org/project/bubus-py310x/)
+[![Downloads](https://static.pepy.tech/badge/bubus-py310x)](https://pepy.tech/project/bubus-py310x)
+[![GitHub stars](https://img.shields.io/github/stars/abhijeetkaze/bubus?style=social)](https://github.com/abhijeetkaze/bubus/stargazers)
+[![Last Commit](https://img.shields.io/github/last-commit/abhijeetkaze/bubus)](https://github.com/abhijeetkaze/bubus/commits/main)
+
+A minimal fork of `bubus` with compatibility fixes for Python 3.10+.  
+
+- Maintainer for Python 3.10 version: **[Abhijeet Mohanta](https://github.com/abhijeetkaze)**
+- `bubus` is mocked to enable compatibility with Python 3.10.
+- Cloud actions are **not supported** in this version.
+- `from typing_extensions import Self` (for Python 3.10 compatibility) is used in place of `Self` from `typing`.
+- `async with asyncio.timeout` replaced with `async_timeout` (custom implementation of async timeout) to support Python 3.10.
+- UTC datetime changed to timezone(UTC = timezone.utc)
+- asyncio.create_task no context passed
+
 ## 🔢 Quickstart
 
 Install bubus and get started with a simple event-driven application:

README.md

@@ -0,0 +1,16 @@
+from contextlib import asynccontextmanager
+import asyncio
+
+@asynccontextmanager
+async def async_timeout(timeout: float):
+    task = asyncio.current_task()
+    loop = asyncio.get_event_loop()
+    if task is None:
+        raise RuntimeError("async_timeout must be used within a running asyncio Task")
+    handle = loop.call_later(timeout, task.cancel)
+    try:
+        yield
+    except asyncio.CancelledError:
+        raise asyncio.TimeoutError(f"Operation exceeded {timeout} seconds")
+    finally:
+        handle.cancel()

bubus/compatible_utils/__init__.py

@@ -7,6 +7,7 @@
 from functools import wraps
 from pathlib import Path
 from typing import Any, Literal, ParamSpec, TypeVar
+from .compatible_utils.async_timeout import async_timeout
 
 import portalocker
 
@@ -219,7 +220,7 @@ async def _acquire_asyncio_semaphore(
 ) -> bool:
     """Acquire an asyncio semaphore."""
     try:
-        async with asyncio.timeout(sem_timeout):
+        async with async_timeout(sem_timeout):
             await semaphore.acquire()
             return True
     except TimeoutError:
@@ -252,7 +253,7 @@ async def _execute_with_retries(
     for attempt in range(retries + 1):
         try:
             # Execute with per-attempt timeout
-            async with asyncio.timeout(timeout):
+            async with async_timeout(timeout):
                 return await func(*args, **kwargs)  # type: ignore[reportCallIssue]
 
         except Exception as e:

bubus/compatible_utils/asyncio_timeout.py

@@ -1,9 +1,13 @@
 """Helper functions for logging event trees and formatting"""
 
 from collections import defaultdict
-from datetime import UTC, datetime
+from datetime import timezone, datetime
 from typing import TYPE_CHECKING, Any
 
+
+# Use timezone.utc directly in your code
+UTC = timezone.utc
+
 if TYPE_CHECKING:
     from bubus.models import BaseEvent, EventResult
     from bubus.service import EventBus

bubus/helpers.py

@@ -5,13 +5,17 @@
 import logging
 import os
 from collections.abc import Awaitable, Callable, Generator
-from datetime import UTC, datetime
-from typing import TYPE_CHECKING, Annotated, Any, Literal, Protocol, Self, TypeAlias, TypeVar, runtime_checkable
+from datetime import timezone, datetime
+from typing import TYPE_CHECKING, Annotated, Any, Literal, Protocol, TypeAlias, TypeVar, runtime_checkable
+from typing_extensions import Self
 from uuid import UUID
 
 from pydantic import AfterValidator, BaseModel, ConfigDict, Field, PrivateAttr, model_validator
 from uuid_extensions import uuid7str
 
+# Use timezone.utc directly in your code
+UTC = timezone.utc
+
 if TYPE_CHECKING:
     from bubus.service import EventBus
 

bubus/logging.py

@@ -796,7 +796,7 @@ async def _execute_handlers(
                 task = asyncio.create_task(
                     self._execute_sync_or_async_handler(event, handler, timeout=timeout),
                     name=f'{self}._execute_sync_or_async_handler({event}, {get_handler_name(handler)})',
-                    context=context,
+                    # context=context,
                 )
                 handler_tasks[handler_id] = (task, handler)