19
19
EventSystemInfoData ,
20
20
)
21
21
22
+ from apify ._utils import docs_group
22
23
from apify .log import logger
23
24
24
25
if TYPE_CHECKING :
30
31
__all__ = ['EventManager' , 'LocalEventManager' , 'PlatformEventManager' ]
31
32
32
33
34
+ @docs_group ('Data structures' )
33
35
class PersistStateEvent (BaseModel ):
34
36
name : Literal [Event .PERSIST_STATE ]
35
37
data : Annotated [EventPersistStateData , Field (default_factory = lambda : EventPersistStateData (is_migrating = False ))]
36
38
37
39
40
+ @docs_group ('Data structures' )
38
41
class SystemInfoEventData (BaseModel ):
39
42
mem_avg_bytes : Annotated [float , Field (alias = 'memAvgBytes' )]
40
43
mem_current_bytes : Annotated [float , Field (alias = 'memCurrentBytes' )]
@@ -61,26 +64,31 @@ def to_crawlee_format(self) -> EventSystemInfoData:
61
64
)
62
65
63
66
67
+ @docs_group ('Data structures' )
64
68
class SystemInfoEvent (BaseModel ):
65
69
name : Literal [Event .SYSTEM_INFO ]
66
70
data : SystemInfoEventData
67
71
68
72
73
+ @docs_group ('Data structures' )
69
74
class MigratingEvent (BaseModel ):
70
75
name : Literal [Event .MIGRATING ]
71
76
data : Annotated [EventMigratingData , Field (default_factory = EventMigratingData )]
72
77
73
78
79
+ @docs_group ('Data structures' )
74
80
class AbortingEvent (BaseModel ):
75
81
name : Literal [Event .ABORTING ]
76
82
data : Annotated [EventAbortingData , Field (default_factory = EventAbortingData )]
77
83
78
84
85
+ @docs_group ('Data structures' )
79
86
class ExitEvent (BaseModel ):
80
87
name : Literal [Event .EXIT ]
81
88
data : Annotated [EventExitData , Field (default_factory = EventExitData )]
82
89
83
90
91
+ @docs_group ('Data structures' )
84
92
class EventWithoutData (BaseModel ):
85
93
name : Literal [
86
94
Event .SESSION_RETIRED ,
@@ -93,11 +101,13 @@ class EventWithoutData(BaseModel):
93
101
data : Any = None
94
102
95
103
104
+ @docs_group ('Data structures' )
96
105
class DeprecatedEvent (BaseModel ):
97
106
name : Literal ['cpuInfo' ]
98
107
data : Annotated [dict [str , Any ], Field (default_factory = dict )]
99
108
100
109
110
+ @docs_group ('Data structures' )
101
111
class UnknownEvent (BaseModel ):
102
112
name : str
103
113
data : Annotated [dict [str , Any ], Field (default_factory = dict )]
@@ -125,6 +135,7 @@ class UnknownEvent(BaseModel):
125
135
)
126
136
127
137
138
+ @docs_group ('Classes' )
128
139
class PlatformEventManager (EventManager ):
129
140
"""A class for managing Actor events.
130
141
0 commit comments