fix: support reusing field-input components in event-driven flows by Copilot · Pull Request #249 · plugboard-dev/plugboard

Copilot · 2026-04-08T20:36:24Z

Summary

Components like FileWriter could not be reused in event-driven models by subclassing and adding event handlers, because process validation still required connector-backed field inputs and shutdown could replay the last event-populated value. This change allows inherited field inputs to be satisfied by events and closes the event-driven path cleanly once producers are exhausted.

Changes

Validation
- Allow components with non-system input_events to have unconnected field inputs.
- This enables subclasses that populate inherited fields from event handlers instead of field connectors.
Runtime behavior
- Treat components with no connected field-input channels as event-driven for producer-graph exhaustion.
- Exit the wrapped step before rebinding inputs when IO closes, preventing stale event-populated values from being replayed on shutdown.
API surface
- Expose IOController.has_connected_field_inputs and use it for the runtime check instead of reaching into internal channel state.
Coverage
- Add a focused integration test showing a FileWriter subclass consuming events to populate message.
- Add a validation test covering the same reuse pattern.

class EventReaderFileWriter(FileWriter):
    io = IO(input_events=[MessageEvent])

    @MessageEvent.handler
    async def handle_message(self, event: MessageEvent) -> None:
        self.message = event.data.message

Warning

Firewall rules blocked me from connecting to one or more addresses (expand for details)

I tried to connect to the following addresses, but was blocked by firewall rules:

metadata.google.internal
- Triggering command: /home/REDACTED/work/plugboard/plugboard/.venv/bin/python3 /home/REDACTED/work/plugboard/plugboard/.venv/bin/python3 /home/REDACTED/work/plugboard/plugboard/.venv/lib/python3.13/site-packages/ray/dashboard/dashboard.py --host=127.0.0.1 --port=8265 --port-retries=50 --temp-dir=/tmp/ray --log-dir=/tmp/ray/session_2026-04-08_20-39-05_496118_4173/logs --session-dir=/tmp/ray/session_2026-04-08_20-39-05_496118_4173 --logging-rotate-bytes=536870912 --logging-rotate-backup-count=5 --gcs-address=127.0.0.1:37769 --cluster-id-hex=12135458e388ceb3b846ca782e5dd938de9648ae360cbb7d94ee0423 --node-ip-address=127.0.0.1 --stdout-filepath=/tmp/ray/session_2026-04-08_20-39-05_496118_4173/logs/dashboard.out --stderr-filepath=/tmp/ray/session_2026-04-08_20-39-05_496118_4173/logs/dashboard.err cal/bin/git (dns block)
- Triggering command: /home/REDACTED/work/plugboard/plugboard/.venv/bin/python3 /home/REDACTED/work/plugboard/plugboard/.venv/bin/python3 /home/REDACTED/work/plugboard/plugboard/.venv/lib/python3.13/site-packages/ray/dashboard/dashboard.py --host=127.0.0.1 --port=8265 --port-retries=50 --temp-dir=/tmp/ray --log-dir=/tmp/ray/session_2026-04-08_20-42-25_298805_5295/logs --session-dir=/tmp/ray/session_2026-04-08_20-42-25_298805_5295 --logging-rotate-bytes=536870912 --logging-rotate-backup-count=5 --gcs-address=127.0.0.1:46503 --cluster-id-hex=7cdaee0fa9731bdb3741caecaaa16ea30c42dd0e00066412731da5bb --node-ip-address=127.0.0.1 --stdout-filepath=/tmp/ray/session_2026-04-08_20-42-25_298805_5295/logs/dashboard.out --stderr-filepath=/tmp/ray/session_2026-04-08_20-42-25_298805_5295/logs/dashboard.err p/bin/git r (dns block)
- Triggering command: /home/REDACTED/work/plugboard/plugboard/.venv/bin/python3 /home/REDACTED/work/plugboard/plugboard/.venv/bin/python3 /home/REDACTED/work/plugboard/plugboard/.venv/lib/python3.13/site-packages/ray/dashboard/dashboard.py --host=127.0.0.1 --port=8265 --port-retries=50 --temp-dir=/tmp/ray --log-dir=/tmp/ray/session_2026-04-08_20-50-35_693193_6522/logs --session-dir=/tmp/ray/session_2026-04-08_20-50-35_693193_6522 --logging-rotate-bytes=536870912 --logging-rotate-backup-count=5 --gcs-address=127.0.0.1:43549 --cluster-id-hex=7a8906b6756dbfd8332941da89ea5d811afa31c7de1ee6047d690f01 --node-ip-address=127.0.0.1 --stdout-filepath=/tmp/ray/session_2026-04-08_20-50-35_693193_6522/logs/dashboard.out --stderr-filepath=/tmp/ray/session_2026-04-08_20-50-35_693193_6522/logs/dashboard.err k/_temp/ghcca-node/node/bin/git 3 /home/REDACTED/wfile (dns block)
releases.astral.sh
- Triggering command: /home/REDACTED/.local/bin/uv uv venv .venv --python python3.13 (dns block)

If you need me to access, download, or install something from one of these locations, you can either:

Configure Actions setup steps to set up my environment, which run before the firewall is enabled
Add the appropriate URLs or hosts to the custom allowlist in this repository's Copilot coding agent settings (admins only)

Agent-Logs-Url: https://github.com/plugboard-dev/plugboard/sessions/b2d74c52-309e-40c7-bdd3-5880ba403b35 Co-authored-by: toby-coleman <13170610+toby-coleman@users.noreply.github.com>

chrisk314 · 2026-04-12T18:09:56Z

+                if self.io.is_closed:
+                    return


This is problematic. _periodic_status_check could raise EventStreamClosedError in the same step where new event data is received. Exiting step here would prevent consumption of final event. I'm looking into it.

…er extension

github-actions · 2026-04-12T19:56:40Z

Benchmark comparison for bd691377 (base) vs 7fe735be (PR)


------------------------------------------------------------------------------------------------------------------ benchmark: 2 tests -----------------------------------------------------------------------------------------------------------------
Name (time in ms)                                                                         Min                 Max                Mean            StdDev              Median               IQR            Outliers     OPS            Rounds  Iterations
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
test_benchmark_process_run (main/.benchmarks/Linux-CPython-3.12-64bit/0001_base)     456.1165 (1.0)      460.9843 (1.0)      458.2025 (1.0)      1.9265 (1.0)      457.6381 (1.0)      2.8699 (1.37)          2;0  2.1824 (1.0)           5           1
test_benchmark_process_run (pr/.benchmarks/Linux-CPython-3.12-64bit/0001_pr)         463.0487 (1.02)     468.0459 (1.02)     466.3941 (1.02)     1.9812 (1.03)     467.3026 (1.02)     2.1025 (1.0)           1;0  2.1441 (0.98)          5           1
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Legend:
  Outliers: 1 Standard Deviation from Mean; 1.5 IQR (InterQuartile Range) from 1st Quartile and 3rd Quartile.
  OPS: Operations Per Second, computed as 1 / Mean

github-actions · 2026-04-16T08:15:23Z

Benchmark comparison for bd691377 (base) vs 5fad4052 (PR)


------------------------------------------------------------------------------------------------------------------ benchmark: 2 tests -----------------------------------------------------------------------------------------------------------------
Name (time in ms)                                                                         Min                 Max                Mean            StdDev              Median               IQR            Outliers     OPS            Rounds  Iterations
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
test_benchmark_process_run (main/.benchmarks/Linux-CPython-3.12-64bit/0001_base)     448.8447 (1.0)      455.4485 (1.0)      451.3727 (1.0)      3.0178 (1.0)      449.8813 (1.0)      5.2007 (1.0)           1;0  2.2155 (1.0)           5           1
test_benchmark_process_run (pr/.benchmarks/Linux-CPython-3.12-64bit/0001_pr)         471.6089 (1.05)     488.7066 (1.07)     478.1191 (1.06)     6.6090 (2.19)     478.1034 (1.06)     7.9465 (1.53)          1;0  2.0915 (0.94)          5           1
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Legend:
  Outliers: 1 Standard Deviation from Mean; 1.5 IQR (InterQuartile Range) from 1st Quartile and 3rd Quartile.
  OPS: Operations Per Second, computed as 1 / Mean

github-actions · 2026-04-16T09:17:48Z

Benchmark comparison for bd691377 (base) vs 8ca62989 (PR)


------------------------------------------------------------------------------------------------------------------ benchmark: 2 tests -----------------------------------------------------------------------------------------------------------------
Name (time in ms)                                                                         Min                 Max                Mean            StdDev              Median               IQR            Outliers     OPS            Rounds  Iterations
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
test_benchmark_process_run (main/.benchmarks/Linux-CPython-3.12-64bit/0001_base)     315.4050 (1.0)      323.5251 (1.01)     319.0175 (1.00)     3.1700 (1.65)     317.7703 (1.0)      4.4508 (1.26)          2;0  3.1346 (1.00)          5           1
test_benchmark_process_run (pr/.benchmarks/Linux-CPython-3.12-64bit/0001_pr)         316.0666 (1.00)     320.4112 (1.0)      318.3733 (1.0)      1.9259 (1.0)      318.3888 (1.00)     3.5349 (1.0)           2;0  3.1410 (1.0)           5           1
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Legend:
  Outliers: 1 Standard Deviation from Mean; 1.5 IQR (InterQuartile Range) from 1st Quartile and 3rd Quartile.
  OPS: Operations Per Second, computed as 1 / Mean

github-actions · 2026-04-29T19:41:34Z

Benchmark comparison for 07750b3c (base) vs 44199ee2 (PR)


------------------------------------------------------------------------------------------------------------------ benchmark: 2 tests -----------------------------------------------------------------------------------------------------------------
Name (time in ms)                                                                         Min                 Max                Mean            StdDev              Median               IQR            Outliers     OPS            Rounds  Iterations
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
test_benchmark_process_run (main/.benchmarks/Linux-CPython-3.14-64bit/0001_base)     353.1617 (1.0)      363.3147 (1.0)      358.3832 (1.0)      4.9831 (1.82)     358.5817 (1.0)      9.8634 (2.65)          1;0  2.7903 (1.0)           5           1
test_benchmark_process_run (pr/.benchmarks/Linux-CPython-3.14-64bit/0001_pr)         362.3338 (1.03)     369.5299 (1.02)     365.6552 (1.02)     2.7418 (1.0)      364.8262 (1.02)     3.7261 (1.0)           2;0  2.7348 (0.98)          5           1
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Legend:
  Outliers: 1 Standard Deviation from Mean; 1.5 IQR (InterQuartile Range) from 1st Quartile and 3rd Quartile.
  OPS: Operations Per Second, computed as 1 / Mean

github-actions · 2026-05-02T12:05:22Z

Benchmark comparison for 07750b3c (base) vs 565213e3 (PR)


------------------------------------------------------------------------------------------------------------------ benchmark: 2 tests -----------------------------------------------------------------------------------------------------------------
Name (time in ms)                                                                         Min                 Max                Mean            StdDev              Median               IQR            Outliers     OPS            Rounds  Iterations
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
test_benchmark_process_run (pr/.benchmarks/Linux-CPython-3.14-64bit/0001_pr)         527.5260 (1.0)      552.2053 (1.01)     536.4902 (1.0)      9.3853 (2.92)     533.2748 (1.0)      9.2487 (1.59)          1;0  1.8640 (1.0)           5           1
test_benchmark_process_run (main/.benchmarks/Linux-CPython-3.14-64bit/0001_base)     538.9802 (1.02)     545.8100 (1.0)      541.7023 (1.01)     3.2185 (1.0)      540.2258 (1.01)     5.8108 (1.0)           1;0  1.8460 (0.99)          5           1
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Legend:
  Outliers: 1 Standard Deviation from Mean; 1.5 IQR (InterQuartile Range) from 1st Quartile and 3rd Quartile.
  OPS: Operations Per Second, computed as 1 / Mean

github-actions · 2026-05-02T12:06:47Z

Benchmark comparison for 07750b3c (base) vs f4466fe9 (PR)


------------------------------------------------------------------------------------------------------------------ benchmark: 2 tests -----------------------------------------------------------------------------------------------------------------
Name (time in ms)                                                                         Min                 Max                Mean            StdDev              Median               IQR            Outliers     OPS            Rounds  Iterations
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
test_benchmark_process_run (main/.benchmarks/Linux-CPython-3.14-64bit/0001_base)     420.5918 (1.0)      424.5709 (1.0)      422.2754 (1.0)      1.6218 (1.0)      422.0734 (1.0)      2.6007 (1.09)          2;0  2.3681 (1.0)           5           1
test_benchmark_process_run (pr/.benchmarks/Linux-CPython-3.14-64bit/0001_pr)         424.5365 (1.01)     429.9366 (1.01)     426.5250 (1.01)     2.0773 (1.28)     425.8785 (1.01)     2.3826 (1.0)           1;0  2.3445 (0.99)          5           1
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Legend:
  Outliers: 1 Standard Deviation from Mean; 1.5 IQR (InterQuartile Range) from 1st Quartile and 3rd Quartile.
  OPS: Operations Per Second, computed as 1 / Mean

github-actions · 2026-05-02T12:59:58Z

Benchmark comparison for 07750b3c (base) vs 32634a0a (PR)


------------------------------------------------------------------------------------------------------------------ benchmark: 2 tests -----------------------------------------------------------------------------------------------------------------
Name (time in ms)                                                                         Min                 Max                Mean            StdDev              Median               IQR            Outliers     OPS            Rounds  Iterations
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
test_benchmark_process_run (pr/.benchmarks/Linux-CPython-3.14-64bit/0001_pr)         535.1394 (1.0)      548.0246 (1.0)      542.7306 (1.0)      4.8230 (1.38)     542.7936 (1.0)      5.5673 (1.15)          2;0  1.8425 (1.0)           5           1
test_benchmark_process_run (main/.benchmarks/Linux-CPython-3.14-64bit/0001_base)     546.9473 (1.02)     555.5848 (1.01)     549.9993 (1.01)     3.5020 (1.0)      549.0817 (1.01)     4.8415 (1.0)           1;0  1.8182 (0.99)          5           1
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Legend:
  Outliers: 1 Standard Deviation from Mean; 1.5 IQR (InterQuartile Range) from 1st Quartile and 3rd Quartile.
  OPS: Operations Per Second, computed as 1 / Mean

codecov · 2026-05-02T13:06:57Z

Codecov Report

❌ Patch coverage is 91.22807% with 5 lines in your changes missing coverage. Please review.

Files with missing lines	Patch %	Lines
plugboard/library/data_writer.py	71.42%	2 Missing and 2 partials ⚠️
plugboard/component/io_controller.py	93.75%	1 Missing ⚠️

📢 Thoughts on this report? Let us know!

github-actions · 2026-05-02T17:47:40Z

Benchmark comparison for 07750b3c (base) vs f92eae8c (PR)


------------------------------------------------------------------------------------------------------------------ benchmark: 2 tests ------------------------------------------------------------------------------------------------------------------
Name (time in ms)                                                                         Min                 Max                Mean            StdDev              Median                IQR            Outliers     OPS            Rounds  Iterations
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
test_benchmark_process_run (pr/.benchmarks/Linux-CPython-3.14-64bit/0001_pr)         539.4641 (1.0)      545.3841 (1.0)      542.2081 (1.0)      2.2095 (1.0)      542.5267 (1.0)       2.7913 (1.0)           2;0  1.8443 (1.0)           5           1
test_benchmark_process_run (main/.benchmarks/Linux-CPython-3.14-64bit/0001_base)     547.7108 (1.02)     564.1873 (1.03)     554.6332 (1.02)     7.7794 (3.52)     550.2784 (1.01)     13.7486 (4.93)          1;0  1.8030 (0.98)          5           1
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Legend:
  Outliers: 1 Standard Deviation from Mean; 1.5 IQR (InterQuartile Range) from 1st Quartile and 3rd Quartile.
  OPS: Operations Per Second, computed as 1 / Mean

Initial plan

b58cb93

Copilot AI assigned Copilot and toby-coleman Apr 8, 2026

Copilot AI linked an issue Apr 8, 2026 that may be closed by this pull request

feat: Improve reusability of components in event-driven simulations #248

Open

Copilot started work on behalf of toby-coleman April 8, 2026 20:36 View session

Copilot AI and others added 7 commits April 8, 2026 20:59

fix: support reusing field-input components in event-driven flows

2536193

Agent-Logs-Url: https://github.com/plugboard-dev/plugboard/sessions/b2d74c52-309e-40c7-bdd3-5880ba403b35 Co-authored-by: toby-coleman <13170610+toby-coleman@users.noreply.github.com>

chore: address review feedback on event-driven reuse fix

e7a822a

Agent-Logs-Url: https://github.com/plugboard-dev/plugboard/sessions/b2d74c52-309e-40c7-bdd3-5880ba403b35 Co-authored-by: toby-coleman <13170610+toby-coleman@users.noreply.github.com>

docs: clarify event-driven reuse shutdown handling

5e39023

Agent-Logs-Url: https://github.com/plugboard-dev/plugboard/sessions/b2d74c52-309e-40c7-bdd3-5880ba403b35 Co-authored-by: toby-coleman <13170610+toby-coleman@users.noreply.github.com>

docs: clarify event-driven reuse test intent

544d5c8

Agent-Logs-Url: https://github.com/plugboard-dev/plugboard/sessions/b2d74c52-309e-40c7-bdd3-5880ba403b35 Co-authored-by: toby-coleman <13170610+toby-coleman@users.noreply.github.com>

refactor: expose connected input state on io controller

b3c4e16

Agent-Logs-Url: https://github.com/plugboard-dev/plugboard/sessions/b2d74c52-309e-40c7-bdd3-5880ba403b35 Co-authored-by: toby-coleman <13170610+toby-coleman@users.noreply.github.com>

refactor: reuse connected input property internally

e4047cb

Agent-Logs-Url: https://github.com/plugboard-dev/plugboard/sessions/b2d74c52-309e-40c7-bdd3-5880ba403b35 Co-authored-by: toby-coleman <13170610+toby-coleman@users.noreply.github.com>

refactor: simplify connected field input checks

b442ee0

Agent-Logs-Url: https://github.com/plugboard-dev/plugboard/sessions/b2d74c52-309e-40c7-bdd3-5880ba403b35 Co-authored-by: toby-coleman <13170610+toby-coleman@users.noreply.github.com>

Copilot AI changed the title ~~[WIP] Improve reusability of components in event-driven simulations~~ fix: support reusing field-input components in event-driven flows Apr 8, 2026

Copilot finished work on behalf of toby-coleman April 8, 2026 21:15

Copilot AI requested a review from toby-coleman April 8, 2026 21:15

fix: Modifies DataWriter logic to only append new data

21b8ea4

chrisk314 requested changes Apr 12, 2026

View reviewed changes

chrisk314 added 3 commits April 12, 2026 20:25

refactor: Separates field data tracker reset into new method for easi…

f763d86

…er extension

refactor: Adapts DataWriter for trickling input data

675e8de

refactor: Rework DataWriter logic

7fe735b

chrisk314 marked this pull request as ready for review April 12, 2026 19:55

fixup! refactor: Rework DataWriter logic

5fad405

test: Adds test for staggered event driven data arrival

8ca6298

chrisk314 added 4 commits April 28, 2026 20:18

Merge branch 'main' into copilot/feat-improve-component-reusability

5378b4c

feat: Adds populates_fields kwarg to Event.handler

a4a2035

chore: Modifies input connection logic for event covered fields

297a9b3

refactor: Alternate approach to track event field coverage

68d31e7

test: Updates validation test

44199ee

chrisk314 added 2 commits May 2, 2026 13:58

refactor: Method attr based approach to populates_fields

21947ce

test: Adds test for populates_fields

f4466fe

chrisk314 force-pushed the copilot/feat-improve-component-reusability branch from 565213e to f4466fe Compare May 2, 2026 12:04

chrisk314 added 4 commits May 2, 2026 14:27

refactor: Improves complexity score

72e4927

ci: Changes max abs complexity to C for io_controller.py with many args

6556160

test: Adds populates_fields on existing tests

e677956

fix: Passes event_field_coverage in DataWriter

32634a0

chrisk314 added 2 commits May 2, 2026 19:45

chore: Removes unrequired comment

b87b64d

chore: Removes unrequired method

f92eae8

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

fix: support reusing field-input components in event-driven flows#249

fix: support reusing field-input components in event-driven flows#249
Copilot wants to merge 27 commits intomainfrom
copilot/feat-improve-component-reusability

Copilot AI commented Apr 8, 2026 •

edited

Loading

Uh oh!

chrisk314 Apr 12, 2026

Uh oh!

github-actions Bot commented Apr 12, 2026

Uh oh!

github-actions Bot commented Apr 16, 2026

Uh oh!

github-actions Bot commented Apr 16, 2026

Uh oh!

github-actions Bot commented Apr 29, 2026

Uh oh!

github-actions Bot commented May 2, 2026

Uh oh!

github-actions Bot commented May 2, 2026

Uh oh!

github-actions Bot commented May 2, 2026

Uh oh!

codecov Bot commented May 2, 2026

Uh oh!

github-actions Bot commented May 2, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Conversation

Copilot AI commented Apr 8, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Summary

Changes

I tried to connect to the following addresses, but was blocked by firewall rules:

Uh oh!

chrisk314 Apr 12, 2026

Choose a reason for hiding this comment

Uh oh!

github-actions Bot commented Apr 12, 2026

Uh oh!

github-actions Bot commented Apr 16, 2026

Uh oh!

github-actions Bot commented Apr 16, 2026

Uh oh!

github-actions Bot commented Apr 29, 2026

Uh oh!

github-actions Bot commented May 2, 2026

Uh oh!

github-actions Bot commented May 2, 2026

Uh oh!

github-actions Bot commented May 2, 2026

Uh oh!

codecov Bot commented May 2, 2026

Codecov Report

Uh oh!

github-actions Bot commented May 2, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Copilot AI commented Apr 8, 2026 •

edited

Loading