@@ -33,19 +33,16 @@ class KinesisFirehoseResponseRecord:
33
33
- https://docs.aws.amazon.com/firehose/latest/dev/data-transformation.html
34
34
"""
35
35
36
- """ Record ID; uniquely identifies this record within the current batch"""
36
+ # Record ID; uniquely identifies this record within the current batch"""
37
37
record_id : str
38
- """processing result, supported value: Ok, Dropped, ProcessingFailed"""
38
+ # Processing result, supported value: Ok, Dropped, ProcessingFailed"""
39
39
result : Literal ["Ok" , "Dropped" , "ProcessingFailed" ]
40
- """ data blob, base64-encoded, optional at init. Allows pass in base64-encoded data directly or
41
- use either function like `data_from_text`, `data_from_json` to populate data"""
40
+ # data blob, base64-encoded, optional at init. Allows pass in base64-encoded data directly or
41
+ # use either function like `data_from_text`, `data_from_json` to populate data"""
42
42
data : Optional [str ] = None
43
- """
44
- Optional: Metadata associated with this record; can contain partition keys
45
- - https://docs.aws.amazon.com/firehose/latest/dev/dynamic-partitioning.html
46
- """
43
+ # Optional: Metadata associated with this record; can contain partition keys
44
+ # See - https://docs.aws.amazon.com/firehose/latest/dev/dynamic-partitioning.html
47
45
metadata : Optional [KinesisFirehoseResponseRecordMetadata ] = None
48
- """Json data for caching json.dump result"""
49
46
_json_data : Optional [Any ] = None
50
47
json_serializer : Callable = json .dumps
51
48
json_deserializer : Callable = json .loads
0 commit comments