Alan-Jowett / CoPilot-For-Consensus / 20343589834 / 15
78%
main: 78%

DEFAULT BRANCH: main
Ran
Files 2
Run time 0s
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst
coverage: 65.678%. Remained the same
20343589834.15

push

github

web-flow 
fix: correct publisher.publish() API call in startup_requeue (#397)

* fix: correct publisher.publish() API call in startup_requeue

The RabbitMQPublisher.publish() method signature is:
  publish(exchange: str, routing_key: str, event: Dict[str, Any])

But startup_requeue.py was calling it with incorrect keyword args:
  publish(event_type=..., data=..., routing_key=..., exchange=...)

This fix:
- Builds the complete event dictionary with event_type, timestamp, and data
- Calls publish() with correct parameter order: exchange, routing_key, event
- Ensures startup requeue works for all services (parsing, chunking, embedding, orchestrator, summarization)

Fixes #396

Signed-off-by: Alan Jowett <alan.jowett@microsoft.com>

* test: update startup_requeue tests to match new publisher.publish() API

Updated test assertions to verify the corrected publisher.publish() signature:
- Changed from: publish(event_type=..., data=..., routing_key=..., exchange=...)
- Changed to: publish(exchange=..., routing_key=..., event={...})

Tests now verify:
- exchange parameter set to 'copilot.events'
- routing_key parameter correctly passed
- event dict contains event_type, timestamp, and data fields
- data dict contains the actual event payload

All test methods updated to match the new API signature.

---------

Signed-off-by: Alan Jowett <alan.jowett@microsoft.com>
Co-authored-by: Alan Jowett <alan.jowett@microsoft.com>

155 of 236 relevant lines covered (65.68%)

0.66 hits per line

Source Files on job orchestrator - 20343589834.15