Skip to content

Commit

Permalink
Fixup to expiration.
Browse files Browse the repository at this point in the history
  • Loading branch information
kfindeisen committed Jun 14, 2024
1 parent 6adb8c0 commit b4e4b7a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -162,7 +162,7 @@ async def main() -> None:
group_id = os.environ["CONSUMER_GROUP"]
topic = os.environ["NEXT_VISIT_TOPIC"]
offset = os.environ["OFFSET"]
expire = os.environ["MESSAGE_EXPIRATION"]
expire = float(os.environ["MESSAGE_EXPIRATION"])
kafka_schema_registry_url = os.environ["KAFKA_SCHEMA_REGISTRY_URL"]
latiss_knative_serving_url = os.environ["LATISS_KNATIVE_SERVING_URL"]
lsstcomcam_knative_serving_url = os.environ["LSSTCOMCAM_KNATIVE_SERVING_URL"]
Expand Down

0 comments on commit b4e4b7a

Please sign in to comment.