Skip to content

Commit

Permalink
fix: stream key (#7)
Browse files Browse the repository at this point in the history
  • Loading branch information
Udit107710 authored Sep 3, 2024
1 parent 98066cd commit 27d1c57
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -214,5 +214,5 @@ def run():
print(json.dumps(sample_record2_stream1))
elif stream["stream"]["name"] == "stream2":
print(json.dumps(sample_record_stream2))
elif stream['stream']['name'] == "sample_record_primary_key_with_dot":
elif stream['stream']['name'] == "primary-key-with-dot":
print(json.dumps(sample_record_primary_key_with_dot))

0 comments on commit 27d1c57

Please sign in to comment.