feat(python-sdk): callback subscribers, queryables, and publisher convenience methods - #66

Draft

lferraz wants to merge 56 commits into

kornia:mainfrom

lferraz:feat/python-sdk-callback-subscriber-queryable

Commits on Apr 5, 2026

feat(python-sdk): queue-backed TypedSubscriber/RawSubscriber with optional timeout
lferraz
committed
1d8e8a2
test(python-sdk): tests for callback subscriber variants

lferraz
and
claude
committed
afadda2
test(python-sdk): tests for callback subscriber variants and async undeclare
lferraz
committed
d7f4de1
fix(python-sdk): move concurrent.futures import to module level, fix undeclare order in async subscribers
lferraz
committed
9e2e9d4
feat(python-sdk): add queryable() and subscriber_callback() methods to NodeContext

lferraz
and
claude
committed
2e0f263
fix(python-sdk): AsyncQueryable wrapper prevents executor leak in queryable_async
lferraz
committed
2846535
feat(python-sdk): export new subscriber/queryable classes; add linting config

lferraz
and
claude
committed
d8f1896
docs(python-sdk): rewrite README for synchronous API with new subscribers/queryables

lferraz
and
claude
committed
2c18ead
chore(python-sdk): replace .flake8 with ruff in pyproject.toml; fix lint

lferraz
and
claude
committed
16c5208
docs(python-sdk): add CONTRIBUTING.md with dev setup, lint config, testing notes

lferraz
and
claude
committed
f0bd66e
chore(python-sdk): add pixi.toml; expand pyproject.toml; fix unused imports

lferraz
and
claude
committed
3c8fcc4
chore(python-sdk): scope F821 suppression to context.py only

lferraz
and
claude
committed
f286310
fix(python-sdk): raise GetSampleTimeout from err; remove global B904 ignore

lferraz
and
claude
committed
a19d90d
chore: add markdownlint config; clean up README and CONTRIBUTING

lferraz
and
claude
committed
ce0b18d
refactor(python-sdk): use TYPE_CHECKING for type annotations in context.py

lferraz
and
claude
committed
2d3ce64
ci: add Python SDK lint and test steps

lferraz
and
claude
committed
9c06330
docs(python-sdk): add CLAUDE.md with conventions, threading model, pitfalls

lferraz
and
claude
committed
fcbac7a
test(python-sdk): add missing tests for publisher/subscriber context methods

lferraz
and
claude
committed
f87ea16
fix(python-sdk): add from __future__ import annotations to context.py

lferraz
and
claude
committed
bdbf7c0
fix(python-sdk): address PR review comments

lferraz
and
claude
committed
0105a09
test(python-sdk): cover PR review fixes — sentinel, _closing flag, decode thread

lferraz
and
claude
committed
485d54e
fix(python-sdk): address new Copilot review comments

lferraz
and
claude
committed
254ada7
fix(python-sdk): move FromString decode off Zenoh thread; replace time.sleep with Event in tests; add pyyaml dep

lferraz
and
claude
committed
afb5ac6
docs(python-sdk): add undeclare() calls to README quick-start examples

lferraz
and
claude
committed
1a543e2
test(python-sdk): undeclare async objects in tests; use try/finally for cleanup

lferraz
and
claude
committed
b59f510
fix(python-sdk): add persistent _closed flag to TypedSubscriber and RawSubscriber

lferraz
and
claude
committed
e854706
fix(python-sdk): polling recv() for multi-consumer safety; fix GC docstrings

lferraz
and
claude
committed
4ccad57

Commits on Apr 6, 2026

fix(python-sdk): set _shutdown before ctx.close() in run_node(); join heartbeat

lferraz
and
claude
committed
e857a4f
fix(python-sdk): broaden try/finally in run_node(); pin Python 3.12 in CI

lferraz
and
claude
committed
e1203c0

Commits on Apr 7, 2026

Commits on Apr 14, 2026

Merge remote-tracking branch 'upstream/main' into feat/python-sdk-callback-subscriber-queryable
lferraz
committed
18ac2b5

Commits on Apr 15, 2026

refactor(python-sdk): remove TypedSubscriber from subscriber.py

lferraz
and
claude
committed
8bc9506
refactor(python-sdk): remove TypedSubscriber from public API and context

lferraz
and
claude
committed
f0a8660
refactor(python-sdk): all callback classes inherit _BaseSubscriber, idempotent undeclare

lferraz
and
claude
committed
1d400ef
test(python-sdk): remove TypedSubscriber tests

lferraz
and
claude
committed
eb34fbe
docs(python-sdk): remove TypedSubscriber references, update subscriber docs

lferraz
and
claude
committed
e96917b
chore(python-sdk): add pixi.lock

lferraz
and
claude
committed
b240353
refactor(python-sdk): callback subscribers use registry.decode() instead of msg_class

lferraz
and
claude
committed
3bc6e64
refactor(python-sdk): subscriber_callback methods drop msg_class, pass schema_registry

lferraz
and
claude
committed
08eff64
fix(python-sdk): remove duplicate heartbeat and fix wrong signature in run_node

lferraz
and
claude
committed
34b4e80
test(python-sdk): update callback tests to use mock registry instead of msg_class

lferraz
and
claude
committed
fd3b4f8
style(python-sdk): ruff format subscriber.py and context.py

lferraz
and
claude
committed
817d137
docs(python-sdk): update callback examples to reflect auto-decode via SchemaRegistry

lferraz
and
claude
committed
70bb99a
refactor(python-sdk): type-annotate handler and registry params in subscriber classes

lferraz
and
claude
committed
4803602
test(python-sdk): update tests for merged callback subscriber classes

lferraz
and
claude
committed
9f489d2
refactor(python-sdk): merge sync/async callback subscribers into one class each

lferraz
and
claude
committed
31b6fcc
docs(python-sdk): update docs for merged callback subscriber classes

lferraz
and
claude
committed
5aded5b
refactor(python-sdk): merge sync/async queryable methods into one each

lferraz
and
claude
committed
c07c124
refactor(python-sdk): rename AsyncQueryable → Queryable

lferraz
and
claude
committed
e173b06
fix(python-sdk): address Copilot review — decode in worker thread, type annotations, cleanup

lferraz
and
claude
committed
42311bf

Commits on Apr 17, 2026

fix(python-sdk): address Copilot review round 2

lferraz
and
claude
committed
6463f04