summaryrefslogtreecommitdiff
path: root/src/apscheduler/eventbrokers
Commit message (Collapse)AuthorAgeFilesLines
* Major refactoringAlex Grönholm2022-09-218-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önholm2022-09-041-6/+16
| | | | is cancelled
* Fixed asyncpg/redis start() while cancelled resulting in an inconsistent ↵Alex Grönholm2022-09-042-5/+9
| | | | cancel scope stack
* Fixed docstring on stop_check_intervalAlex Grönholm2022-09-032-5/+6
|
* Don't report cancellations as crashes on Python 3.7Alex Grönholm2022-09-031-2/+9
|
* Improved the MQTT event brokerAlex Grönholm2022-09-031-3/+20
| | | | | * Connection success, failure and disconnection events are now logged * The client parameter is now optional
* Improved the asyncpg event brokerAlex Grönholm2022-09-031-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önholm2022-09-032-35/+169
| | | | connectivity failures
* Added explicit type for unresolvable parameterAlex Grönholm2022-08-171-0/+1
|
* Added missing docstrings to classesAlex Grönholm2022-07-315-0/+86
|
* Made the apscheduler.events module private and re-exported its codeAlex Grönholm2022-07-317-10/+10
|
* Made the apscheduler.enums and apscheduler.exceptions modules private and ↵Alex Grönholm2022-07-302-2/+2
| | | | re-exported their code
* Implemented (un)marshalling for eventsAlex Grönholm2022-07-271-3/+3
| | | | This fixes JSON (de)serialization of certain events.
* Fixed asyncpg event broker not having a "serializer" attributeAlex Grönholm2022-07-241-4/+9
|
* Added support for starting the sync scheduler (and worker) without the ↵Alex Grönholm2022-07-197-86/+105
| | | | context manager
* Fixed return type annotation of AsyncpgEventBroker.__aenter__()Alex Grönholm2022-07-191-1/+1
|
* Switched to Black for code formattingAlex Grönholm2022-04-207-45/+95
|
* Upgraded syntax and switched linting over to pre-commit.ciAlex Grönholm2022-01-024-12/+12
| | | | Linting checks are now run by pre-commit.ci instead of GitHub Actions.
* Upgraded redis dependencyAlex Grönholm2022-01-021-4/+2
|
* Upgraded attrs and its importsAlex Grönholm2022-01-027-38/+38
| | | | We now import "attrs" instead of "attr".
* Implemented one-shot event subscriptionsAlex Grönholm2021-09-133-19/+34
| | | | Such subscriptions are delivered the first matching event and then unsubscribed automatically.
* Guard subscriptions in the synchronous local event broker with a lockAlex Grönholm2021-09-121-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 subscriptionsAlex Grönholm2021-09-121-2/+3
|
* Improved the event subscription systemAlex Grönholm2021-09-123-17/+27
| | | | The subscribe() method now returns a subscription which has the unsubscribe() method in itself.
* Refactored event brokers to use exit stacksAlex Grönholm2021-09-127-50/+42
|
* Implemented a pluggable event broker systemAlex Grönholm2021-09-118-0/+456