Skip to content

Commit

Permalink
add logging of fan out message
Browse files Browse the repository at this point in the history
  • Loading branch information
dspeck1 committed Oct 2, 2024
1 parent 98b7791 commit 7afbcfe
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions python/activator/activator.py
Original file line number Diff line number Diff line change
Expand Up @@ -206,6 +206,7 @@ def keda_start():
next_visit_fan_out_consumer.subscribe([next_visit_fan_out_topic])
next_visit_fan_out_message = next_visit_fan_out_consumer.consume(num_messages=1, timeout=5)

_log.info(next_visit_fan_out_message[0])
visit = FannedOutVisit(next_visit_fan_out_message[0])
process_visit(visit)

Expand Down

0 comments on commit 7afbcfe

Please sign in to comment.