File tree Expand file tree Collapse file tree 2 files changed +8
-8
lines changed Expand file tree Collapse file tree 2 files changed +8
-8
lines changed Original file line number Diff line number Diff line change 31
31
'ce-time'
32
32
}
33
33
34
+
34
35
# TODO(slinkydeveloper) is this really needed?
35
36
class EventGetterSetter (object ):
36
37
@@ -143,9 +144,11 @@ def UnmarshalBinary(
143
144
body : typing .IO ,
144
145
data_unmarshaller : typing .Callable
145
146
):
146
- # Extract only CloudEvent fields from headers
147
- ce_fields = [field for field in headers if \
148
- (field in _ce_required_fields ) or (field in _ce_optional_fields )]
147
+ # Extract only CloudEvent fields from headers
148
+ ce_fields = [
149
+ field for field in headers if
150
+ (field in _ce_required_fields ) or (field in _ce_optional_fields )
151
+ ]
149
152
150
153
headers = {key : headers [key ] for key in ce_fields }
151
154
for header , value in headers .items ():
Original file line number Diff line number Diff line change 44
44
import json
45
45
import typing
46
46
47
- from cloudevents .sdk import converters
48
47
from cloudevents .sdk import marshaller
49
48
50
49
from cloudevents .sdk .event import base
51
50
from cloudevents .sdk .event import v1
52
51
53
- import requests
54
-
55
52
56
53
class Event (base .BaseEvent ):
57
54
"""
@@ -114,8 +111,8 @@ def __init__(
114
111
else :
115
112
raise NotImplementedError
116
113
117
- self .headers = headers
118
- self .data = data
114
+ self .headers = copy . deepcopy ( headers )
115
+ self .data = copy . deepcopy ( data )
119
116
self .marshall = marshaller .NewDefaultHTTPMarshaller ()
120
117
self .event_handler = v1 .Event ()
121
118
self .marshall .FromRequest (
You can’t perform that action at this time.
0 commit comments