Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions .pre-commit-config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ repos:
- id: check-yaml

- repo: https://github.com/astral-sh/ruff-pre-commit
rev: v0.15.9
rev: v0.17.4
hooks:
- id: ruff
args: [--fix, --exit-non-zero-on-fix, --show-fixes]
Expand All @@ -32,7 +32,7 @@ repos:

# Type checking
- repo: https://github.com/pre-commit/mirrors-mypy
rev: v1.20.0
rev: v2.4.1
hooks:
- id: mypy
files: 'src/.*\.py$'
Expand Down
2 changes: 1 addition & 1 deletion README.rst
Original file line number Diff line number Diff line change
Expand Up @@ -39,4 +39,4 @@ To achieve more complex workflows services can be interconnected using
`recipes`_ whereby the output of one service can be directed
onwards to other services.

.. _recipes: https://github.com/DiamondLightSource/python-workflows/tree/main/src/workflows/recipe/README.MD
.. _recipes: https://github.com/DiamondLightSource/python-workflows/tree/main/src/workflows/recipe/README.md
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
## Recipes

A [service](../services/README.MD) listens on a [channel](../transport/README.MD), acts on incoming messages, and produces some output.
A [service](../services/README.md) listens on a [channel](../transport/README.md), acts on incoming messages, and produces some output.
The place where this output is sent to could be hardcoded, ie. written into the source code of the service.
This makes the service structure rigid, and connecting one service to the output of another requires coordinating the source code of both services.
Naturally, this approach does not scale well.
Expand Down
File renamed without changes.
2 changes: 1 addition & 1 deletion src/workflows/transport/common_transport.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ class CommonTransport:
Contains e.g. the logic to manage subscriptions and transactions.
"""

__callback_interceptor = None
__callback_interceptor: Callable[[MessageCallback], MessageCallback] | None = None
__subscriptions: dict[int, dict[str, Any]] = {}
__subscription_id: int = 0
__transactions: set[int] = set()
Expand Down
Loading