[FEA] Lightweight event log runtime detector (#2082)#2086

Merged

sayedbilalbari merged 29 commits intoNVIDIA:devfrom

sayedbilalbari:sbari-issue-2082

Apr 28, 2026

Commits on Apr 23, 2026

docs(spec): lightweight event log runtime detector (issue #2082)

sayedbilalbari
and
claude
committed
docs(spec): address review findings on event log runtime detector spec

sayedbilalbari
and
claude
committed
docs(spec): reframe event log detector as best-effort early routing

sayedbilalbari
and
claude
committed
docs(spec): tighten decision rule and Databricks-rolling scan shape

sayedbilalbari
and
claude
committed
docs(spec): pin memory contract and frame max_events_scanned as cost cap

sayedbilalbari
and
claude
committed
docs(plan): event log runtime detector implementation plan

sayedbilalbari
and
claude
committed
build(user_tools): add zstandard dep for event log detector

sayedbilalbari
and
claude
committed
feat(eventlog_detector): package skeleton and public re-exports

sayedbilalbari
and
claude
committed
feat(eventlog_detector): routing types and exception hierarchy

sayedbilalbari
and
claude
committed
feat(eventlog_detector): Scala-pinned markers module

sayedbilalbari
and
claude
committed
feat(eventlog_detector): classifier mirroring Scala priority

sayedbilalbari
and
claude
committed
feat(eventlog_detector): context-managed codec-aware line streamer

sayedbilalbari
and
claude
committed
feat(eventlog_detector): single-file and Databricks rolling-dir resolver

sayedbilalbari
and
claude
committed
feat(eventlog_detector): bounded streaming scanner across files

sayedbilalbari
and
claude
committed
feat(eventlog_detector): top-level detect_spark_runtime entry point

sayedbilalbari
and
claude
committed
test(eventlog_detector): anchor parity tests on Scala fixtures

sayedbilalbari
and
claude
committed
chore(eventlog_detector): resolve lint findings from full-suite run

sayedbilalbari
and
claude
committed
docs(spec): record realized fixture inventory for event log detector

sayedbilalbari
and
claude
committed
chore(eventlog_detector): fix E302 blank-line lint in stream.py

sayedbilalbari
and
claude
committed
fix(eventlog_detector): narrow _parse_bool to Scala toBoolean semantics

sayedbilalbari
and
claude
committed
fix(eventlog_detector): whitelist supported codec suffixes

sayedbilalbari
and
claude
committed
fix(eventlog_detector): track last-scanned file for event_log_path

sayedbilalbari
and
claude
committed
docs: remove local implementation plan from the PR
sayedbilalbari
committed
docs: remove local design spec from the PR
sayedbilalbari
committed
docs(eventlog_detector): trim docstrings and drop internal references
sayedbilalbari
committed
fix(eventlog_detector): address review findings
sayedbilalbari
committed

Commits on Apr 25, 2026

feat: streamline event log runtime detection
sayedbilalbari
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[FEA] Lightweight event log runtime detector (#2082)#2086

[FEA] Lightweight event log runtime detector (#2082)#2086
sayedbilalbari merged 29 commits intoNVIDIA:devfrom
sayedbilalbari:sbari-issue-2082

Commits on Apr 23, 2026

docs(spec): lightweight event log runtime detector (issue #2082)

docs(spec): address review findings on event log runtime detector spec

docs(spec): reframe event log detector as best-effort early routing

docs(spec): tighten decision rule and Databricks-rolling scan shape

docs(spec): pin memory contract and frame max_events_scanned as cost cap

docs(plan): event log runtime detector implementation plan

build(user_tools): add zstandard dep for event log detector

feat(eventlog_detector): package skeleton and public re-exports

feat(eventlog_detector): routing types and exception hierarchy

feat(eventlog_detector): Scala-pinned markers module

feat(eventlog_detector): classifier mirroring Scala priority

feat(eventlog_detector): context-managed codec-aware line streamer

feat(eventlog_detector): single-file and Databricks rolling-dir resolver

feat(eventlog_detector): bounded streaming scanner across files

feat(eventlog_detector): top-level detect_spark_runtime entry point

test(eventlog_detector): anchor parity tests on Scala fixtures

chore(eventlog_detector): resolve lint findings from full-suite run

docs(spec): record realized fixture inventory for event log detector

chore(eventlog_detector): fix E302 blank-line lint in stream.py

fix(eventlog_detector): narrow _parse_bool to Scala toBoolean semantics

fix(eventlog_detector): whitelist supported codec suffixes

fix(eventlog_detector): track last-scanned file for event_log_path

docs: remove local implementation plan from the PR

docs: remove local design spec from the PR

docs(eventlog_detector): trim docstrings and drop internal references

fix(eventlog_detector): address review findings

Commits on Apr 25, 2026

feat: streamline event log runtime detection

Commits on Apr 28, 2026

test: address event log detector review feedback

test: trim event log detector coverage overlap