Claude/logging#88

Closed

brian-arnold wants to merge 261 commits intonauticalab:mainfrom

brian-arnold:claude/logging

This pull request is big! We're only showing the most recent 250 commits

Commits on Dec 2, 2025

feature: cache packet output schema hash, use logging
eywalker
committed
refactor: Lazily compute packet function output schema hash and explicitly define function pod constructor parameters.
eywalker
committed

Commits on Jan 19, 2026

refactor: standardize schema type usage from `PythonSchema` to `Schema` and refine `ContentHash` methods.
eywalker
committed

Commits on Feb 18, 2026

refactor: rename OrcapodBase and OrcapodObject to Traceable
eywalker
committed

Commits on Feb 25, 2026

refactor: rename PythonSchema to Schema and refactor types
eywalker
committed

Commits on Feb 27, 2026

Commits on Feb 28, 2026

Commits on Mar 1, 2026

Commits on Mar 2, 2026

feat(core): add persistent function/operator nodes
eywalker
committed

Commits on Mar 4, 2026

feat(pipeline): add PersistentSourceNode caching
eywalker
committed
feat(core): add source_id to DerivedSource
eywalker
committed
refactor(core): improve typing in streams
eywalker
committed
feat(core): add packet function executor system

claude
authored and
eywalker
committed
feat(core): add executor param to function_pod decorator, fix constructor validation

claude
authored and
eywalker
committed
feat(core): add concurrent execution path in iter_packets

claude
authored and
eywalker
committed
docs(design): add unified async channel execution system design and plan

claude
authored and
eywalker
committed
docs(design): add thread safety section to channel design

claude
authored and
eywalker
committed
feat(core): implement async channel execution system

claude
authored and
eywalker
committed
test(channels): add concrete pipeline example with sync/async equivalence

claude
authored and
eywalker
committed
docs(design-issues): add O1 — streaming/incremental async_execute overrides for operators

claude
authored and
eywalker
committed
docs(design-issues): add G1 — PodGroup abstraction for composite pod patterns

claude
authored and
eywalker
committed
docs(design-issues): promote AddResult to first-class pod type (G1), split PodGroup to G2

claude
authored and
eywalker
committed
docs(design-issues): clarify AddResult as fused implementation, not a third provenance category

claude
authored and
eywalker
committed
docs(design): add sync/async execution, channels, executors, pipeline compilation, fused pods

claude
authored and
eywalker
committed
ci(tests): trigger test workflow on dev branch

claude
authored and
eywalker
committed
ci(tests): install graphviz system dependencies for pygraphviz

claude
authored and
eywalker
committed
fix(ci): remove stale tkinter import and drop unsupported Python 3.10 from matrix

claude
authored and
eywalker
committed
docs: add Google style docstring convention to LLM guides

claude
authored and
eywalker
committed
docs: convert all docstrings to Google style

claude
authored and
eywalker
committed
fix(core): address multiple async execution and delegation bugs

claude
authored and
eywalker
committed
fix(core): preserve source_info in _materialize_to_stream and fix RayExecutor

claude
authored and
eywalker
committed
fix(protocols): use PacketFunctionProtocol instead of Any in executor protocol

claude
authored and
eywalker
committed
test(core): add regression tests for all executor/async fixes

claude
authored and
eywalker
committed
docs: add comprehensive TODO analysis with priorities and action plan

claude
authored and
eywalker
committed
docs(design-issues): integrate TODO audit into DESIGN_ISSUES.md

claude
authored and
eywalker
committed
feat(pipeline): implement AsyncPipelineOrchestrator for push-based DAG execution

claude
authored and
eywalker
committed

Commits on Mar 5, 2026

feat(operators): implement native streaming async_execute for all operators

claude
authored and
eywalker
committed
docs(design): add async operator strategy discussion with Kafka/Flink comparison

claude
authored and
eywalker
committed
fix(operators): add strict validation to streaming async_execute paths

claude
authored and
eywalker
committed
docs: add async_execute plan for Node classes

claude
authored and
eywalker
committed
docs(plan): comprehensive plan for process_packet/async_process_packet unification

claude
authored and
eywalker
committed
docs(plan): address concurrent paths — route through async_process_packet, remove _execute_concurrent

claude
authored and
eywalker
committed
feat: add async_execute to Node classes, unify process_packet interface

claude
authored and
eywalker
committed
test(channels): add async pipeline → sync DB retrieval examples

claude
authored and
eywalker
committed
test(pipeline): add Pipeline + @function_pod + async orchestrator integration test

claude
authored and
eywalker
committed
fix(function_pod): route FunctionNode.async_execute through async_process_packet

claude
authored and
eywalker
committed
test(pipeline): rewrite async integration test as single cohesive example

claude
authored and
eywalker
committed
refactor(orchestrator): run persistent nodes, return None

claude
authored and
eywalker
committed
fix(operators): address Copilot review comments on async execution

claude
authored and
eywalker
committed
feat(join): restore streaming symmetric hash join with correct system tags

claude
authored and
eywalker
committed
test(system-tags): add sync vs async system-tag equivalence tests

claude
authored and
eywalker
committed
refactor(join): pass pipeline hashes to async_execute instead of storing state

claude
authored and
eywalker
committed
feat(core): introduce node-based graph
eywalker
committed
feat(packet_function): support async functions in PythonPacketFunction

claude
authored and
eywalker
committed
fix(function_node): add concurrent execution to PersistentFunctionNode.async_execute

claude
authored and
eywalker
committed
docs(examples): rewrite async example as 2x2 comparison matrix

claude
authored and
eywalker
committed
docs(examples): use GIL-holding busy-wait to show async vs thread-pool gap

claude
authored and
eywalker
committed
fix: address Copilot PR review comments on async packet support

claude
authored and
eywalker
committed
test: add comprehensive specification-derived test suite

claude
authored and
eywalker
committed
ci: add GitHub Actions workflow for objective tests

claude
authored and
eywalker
committed
fix(test-objective): address CI failures and Copilot review feedback

claude
authored and
eywalker
committed
refactor(hashing): consolidate file hashing via PathStructConverter

claude
authored and
eywalker
committed
fix(hashing): handle BasicFileHasher returning raw bytes in hash_struct_dict

claude
authored and
eywalker
committed
fix(hashing): make hash_file return ContentHash instead of raw bytes

claude
authored and
eywalker
committed
fix(hashing): store full ContentHash string in CachedFileHasher cache

claude
authored and
eywalker
committed
test(hashing): add file hasher return type and CachedFileHasher tests

claude
authored and
eywalker
committed
feat(hashing): add mtime+size cache busting to CachedFileHasher

claude
authored and
eywalker
committed

Commits on Mar 6, 2026

Add tzdata to pyproject.toml

Brian Arnold
authored and
eywalker
committed
Added filtering to the drop-columns logic

Brian Arnold
authored and
eywalker
committed
Fix 3-way Join DuplicateError by using index-based suffixes for colliding columns

Brian Arnold
authored and
eywalker
committed
Add back in changes from commit 60b5a

Brian Arnold
authored and
eywalker
committed
Replace all_info=True with explicit column config in Join.static_process.

Brian Arnold
authored and
eywalker
committed

Commits on Mar 10, 2026

Added GenericAliasHandler class

Brian Arnold
authored and
eywalker
committed
- Added SpecialFormHandler class to builtin_handlers.py — handles typing._SpecialForm objects (like typing.Union) that appear as __origin__ on typing generics

Brian Arnold
authored and
eywalker
committed

Commits on Mar 11, 2026

Restore pipeline-level execution engine API and fix Ray Client serialisation

Brian Arnold
authored and
eywalker
committed
Simplify function_pod wrapper and RayExecutor serialisation

Brian Arnold
authored and
eywalker
committed
fix: explicit pipeline config overrides async default when execution engine provided

Brian Arnold
authored and
eywalker
committed
Add tests for function_pod wrapper pattern and pipeline execution engine API

Brian Arnold
authored and
eywalker
committed
Address PR review comments on Ray execution engine integration

Brian Arnold
authored and
eywalker
committed
fix(executor): have executor protocol return Self

Brian Arnold
authored and
eywalker
committed

Commits on Mar 12, 2026

feat(pipeline): add SourceCacheMode with OFF mode for source nodes

claude
authored and
eywalker
committed
refactor(sources): decouple source caching from pipeline

claude
authored and
eywalker
committed
test(source-node): add tests for SourceNode delegation and CachedSource pipeline integration

claude
authored and
eywalker
committed
refactor(cached-source): remove run() method, use flow() for eager caching

claude
authored and
eywalker
committed
feat(cached-source): add staleness detection against wrapped source

claude
authored and
eywalker
committed
refactor(cached-source): override is_stale property instead of private method

claude
authored and
eywalker
committed
refactor(nodes): delegate data_context to wrapped entity, address Copilot review

claude
authored and
eywalker
committed

Commits on Mar 13, 2026

Commits on Mar 14, 2026

Commits on Mar 15, 2026

Commits on Mar 17, 2026

feat(logging): add logging infrastructure
Brian Arnold
committed