Skip to content

Commit

Permalink
minor updates
Browse files Browse the repository at this point in the history
  • Loading branch information
dontseyit committed May 29, 2024
1 parent 4cbd28f commit 64fccb2
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ The service requires the following configuration parameters:

- **`kafka_ssl_keyfile`** *(string)*: Optional filename containing the client private key. Default: `""`.

- **`kafka_ssl_password`** *(string)*: Optional password to be used for the client private key. Default: `""`.
- **`kafka_ssl_password`** *(string, format: password)*: Optional password to be used for the client private key. Default: `""`.

- **`generate_correlation_id`** *(boolean)*: A flag, which, if False, will result in an error when inbound requests don't possess a correlation ID. If True, requests without a correlation ID will be assigned a newly generated ID in the correlation ID middleware function. Default: `true`.

Expand Down
2 changes: 1 addition & 1 deletion src/metldata/transform/source_event_subscriber.py
Original file line number Diff line number Diff line change
Expand Up @@ -54,5 +54,5 @@ async def _consume_validated(
type_ (str): The type of the event.
topic (str): Name of the topic the event was published to.
"""
submission_event_payload = SubmissionEventPayload(**payload)
submission_event_payload = SubmissionEventPayload(**payload) # type: ignore
await self._run_workflow_func(submission_event_payload)

0 comments on commit 64fccb2

Please sign in to comment.