@@ -67,12 +67,13 @@ def to_sse_event(self) -> Tuple[Optional[bytes], Optional[bytes]]:
67
67
68
68
69
69
class BaseEventStream :
70
+ @staticmethod
70
71
@overload
71
- def event (self , event : Literal ["thread.created" ], data : Thread ) -> Event : ...
72
+ def event (event : Literal ["thread.created" ], data : Thread ) -> Event : ...
72
73
74
+ @staticmethod
73
75
@overload
74
76
def event (
75
- self ,
76
77
event : Literal [
77
78
"thread.run.created" ,
78
79
"thread.run.queued" ,
@@ -88,9 +89,9 @@ def event(
88
89
data : Run ,
89
90
) -> Event : ...
90
91
92
+ @staticmethod
91
93
@overload
92
94
def event (
93
- self ,
94
95
event : Literal [
95
96
"thread.run.step.created" ,
96
97
"thread.run.step.in_progress" ,
@@ -102,14 +103,13 @@ def event(
102
103
data : RunStep ,
103
104
) -> Event : ...
104
105
106
+ @staticmethod
105
107
@overload
106
- def event (
107
- self , event : Literal ["thread.run.step.delta" ], data : RunStepDelta
108
- ) -> Event : ...
108
+ def event (event : Literal ["thread.run.step.delta" ], data : RunStepDelta ) -> Event : ...
109
109
110
+ @staticmethod
110
111
@overload
111
112
def event (
112
- self ,
113
113
event : Literal [
114
114
"thread.message.created" ,
115
115
"thread.message.in_progress" ,
@@ -119,20 +119,22 @@ def event(
119
119
data : Message ,
120
120
) -> Event : ...
121
121
122
+ @staticmethod
122
123
@overload
123
- def event (
124
- self , event : Literal ["thread.message.delta" ], data : MessageDelta
125
- ) -> Event : ...
124
+ def event (event : Literal ["thread.message.delta" ], data : MessageDelta ) -> Event : ...
126
125
126
+ @staticmethod
127
127
@overload
128
- def event (self , event : Literal ["error" ], data : ErrorObject ) -> Event : ...
128
+ def event (event : Literal ["error" ], data : ErrorObject ) -> Event : ...
129
129
130
+ @staticmethod
130
131
@overload
131
- def event (self , event : None , data : ChatCompletionChunk ) -> Event : ...
132
+ def event (event : None , data : ChatCompletionChunk ) -> Event : ...
132
133
133
- def event (self , event : Optional [EventType ], data : EventData ) -> Event :
134
+ @staticmethod
135
+ def event (event : Optional [EventType ], data : EventData ) -> Event :
134
136
"""
135
- Create a server sent event payload with optional event.type and event.data payloads
137
+ Create a server sent event payload with event.type (optional) and event.data payloads
136
138
"""
137
139
return Event (event , data )
138
140
0 commit comments