Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Major refactoring | Alex Grönholm | 2022-09-21 | 8 | -431/+124 |
| | | | | | | | | - Made SyncScheduler a synchronous wrapper for AsyncScheduler - Removed workers as a user interface - Removed synchronous interfaces for data stores and event brokers and refactored existing implementations to use the async interface - Added the current_async_scheduler contextvar - Added job executors | ||||
* | Fixed resource warnings in the asyncpg event broker when the listener task ↵ | Alex Grönholm | 2022-09-04 | 1 | -6/+16 |
| | | | | is cancelled | ||||
* | Fixed asyncpg/redis start() while cancelled resulting in an inconsistent ↵ | Alex Grönholm | 2022-09-04 | 2 | -5/+9 |
| | | | | cancel scope stack | ||||
* | Fixed docstring on stop_check_interval | Alex Grönholm | 2022-09-03 | 2 | -5/+6 |
| | |||||
* | Don't report cancellations as crashes on Python 3.7 | Alex Grönholm | 2022-09-03 | 1 | -2/+9 |
| | |||||
* | Improved the MQTT event broker | Alex Grönholm | 2022-09-03 | 1 | -3/+20 |
| | | | | | * Connection success, failure and disconnection events are now logged * The client parameter is now optional | ||||
* | Improved the asyncpg event broker | Alex Grönholm | 2022-09-03 | 1 | -39/+108 |
| | | | | | | * It now recovers from a server disconnection * Replaced from_asyncpg_pool() with from_dsn() * Only copy the connection options from the async engine in from_async_sqla_engine() | ||||
* | Added async Redis event broker and made the sync one resistant to ↵ | Alex Grönholm | 2022-09-03 | 2 | -35/+169 |
| | | | | connectivity failures | ||||
* | Added explicit type for unresolvable parameter | Alex Grönholm | 2022-08-17 | 1 | -0/+1 |
| | |||||
* | Added missing docstrings to classes | Alex Grönholm | 2022-07-31 | 5 | -0/+86 |
| | |||||
* | Made the apscheduler.events module private and re-exported its code | Alex Grönholm | 2022-07-31 | 7 | -10/+10 |
| | |||||
* | Made the apscheduler.enums and apscheduler.exceptions modules private and ↵ | Alex Grönholm | 2022-07-30 | 2 | -2/+2 |
| | | | | re-exported their code | ||||
* | Implemented (un)marshalling for events | Alex Grönholm | 2022-07-27 | 1 | -3/+3 |
| | | | | This fixes JSON (de)serialization of certain events. | ||||
* | Fixed asyncpg event broker not having a "serializer" attribute | Alex Grönholm | 2022-07-24 | 1 | -4/+9 |
| | |||||
* | Added support for starting the sync scheduler (and worker) without the ↵ | Alex Grönholm | 2022-07-19 | 7 | -86/+105 |
| | | | | context manager | ||||
* | Fixed return type annotation of AsyncpgEventBroker.__aenter__() | Alex Grönholm | 2022-07-19 | 1 | -1/+1 |
| | |||||
* | Switched to Black for code formatting | Alex Grönholm | 2022-04-20 | 7 | -45/+95 |
| | |||||
* | Upgraded syntax and switched linting over to pre-commit.ci | Alex Grönholm | 2022-01-02 | 4 | -12/+12 |
| | | | | Linting checks are now run by pre-commit.ci instead of GitHub Actions. | ||||
* | Upgraded redis dependency | Alex Grönholm | 2022-01-02 | 1 | -4/+2 |
| | |||||
* | Upgraded attrs and its imports | Alex Grönholm | 2022-01-02 | 7 | -38/+38 |
| | | | | We now import "attrs" instead of "attr". | ||||
* | Implemented one-shot event subscriptions | Alex Grönholm | 2021-09-13 | 3 | -19/+34 |
| | | | | Such subscriptions are delivered the first matching event and then unsubscribed automatically. | ||||
* | Guard subscriptions in the synchronous local event broker with a lock | Alex Grönholm | 2021-09-12 | 1 | -4/+12 |
| | | | | This allows the local event broker to safely iterate through the original list of subscriptions while publishing an event, instead of having to atomically make a shallow copy every time. | ||||
* | Added context manager support to event subscriptions | Alex Grönholm | 2021-09-12 | 1 | -2/+3 |
| | |||||
* | Improved the event subscription system | Alex Grönholm | 2021-09-12 | 3 | -17/+27 |
| | | | | The subscribe() method now returns a subscription which has the unsubscribe() method in itself. | ||||
* | Refactored event brokers to use exit stacks | Alex Grönholm | 2021-09-12 | 7 | -50/+42 |
| | |||||
* | Implemented a pluggable event broker system | Alex Grönholm | 2021-09-11 | 8 | -0/+456 |