Skip to content

Commit

Permalink
Assign blessed_key to metadata if blessed_key is defined (faust-strea…
Browse files Browse the repository at this point in the history
…ming#422)

* Assign blessed_key to metadata if blessed_key is defined

* just assign _blessed_key from hereon
  • Loading branch information
wbarnha authored Dec 15, 2022
1 parent ae685ef commit e541793
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion faust/models/record.py
Original file line number Diff line number Diff line change
Expand Up @@ -592,7 +592,7 @@ def to_representation(self) -> Mapping[str, Any]:
payload = self.asdict()
options = self._options
if options.include_metadata:
payload["__faust"] = {"ns": options.namespace}
payload[self._blessed_key] = {"ns": options.namespace}
return payload

def asdict(self) -> Dict[str, Any]: # pragma: no cover
Expand Down

0 comments on commit e541793

Please sign in to comment.