21
21
22
22
from apify .log import logger
23
23
24
+ from apify ._utils import docs_group
25
+
24
26
if TYPE_CHECKING :
25
27
from types import TracebackType
26
28
29
31
30
32
__all__ = ['EventManager' , 'LocalEventManager' , 'PlatformEventManager' ]
31
33
32
-
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
+ @ docs_group ( 'Data structures' )
38
40
class SystemInfoEventData (BaseModel ):
39
41
mem_avg_bytes : Annotated [float , Field (alias = 'memAvgBytes' )]
40
42
mem_current_bytes : Annotated [float , Field (alias = 'memCurrentBytes' )]
@@ -60,27 +62,27 @@ def to_crawlee_format(self) -> EventSystemInfoData:
60
62
}
61
63
)
62
64
63
-
65
+ @ docs_group ( 'Data structures' )
64
66
class SystemInfoEvent (BaseModel ):
65
67
name : Literal [Event .SYSTEM_INFO ]
66
68
data : SystemInfoEventData
67
69
68
-
70
+ @ docs_group ( 'Data structures' )
69
71
class MigratingEvent (BaseModel ):
70
72
name : Literal [Event .MIGRATING ]
71
73
data : Annotated [EventMigratingData , Field (default_factory = EventMigratingData )]
72
74
73
-
75
+ @ docs_group ( 'Data structures' )
74
76
class AbortingEvent (BaseModel ):
75
77
name : Literal [Event .ABORTING ]
76
78
data : Annotated [EventAbortingData , Field (default_factory = EventAbortingData )]
77
79
78
-
80
+ @ docs_group ( 'Data structures' )
79
81
class ExitEvent (BaseModel ):
80
82
name : Literal [Event .EXIT ]
81
83
data : Annotated [EventExitData , Field (default_factory = EventExitData )]
82
84
83
-
85
+ @ docs_group ( 'Data structures' )
84
86
class EventWithoutData (BaseModel ):
85
87
name : Literal [
86
88
Event .SESSION_RETIRED ,
@@ -92,12 +94,12 @@ class EventWithoutData(BaseModel):
92
94
]
93
95
data : Any = None
94
96
95
-
97
+ @ docs_group ( 'Data structures' )
96
98
class DeprecatedEvent (BaseModel ):
97
99
name : Literal ['cpuInfo' ]
98
100
data : Annotated [dict [str , Any ], Field (default_factory = dict )]
99
101
100
-
102
+ @ docs_group ( 'Data structures' )
101
103
class UnknownEvent (BaseModel ):
102
104
name : str
103
105
data : Annotated [dict [str , Any ], Field (default_factory = dict )]
@@ -123,8 +125,7 @@ class UnknownEvent(BaseModel):
123
125
UnknownEvent ,
124
126
]
125
127
)
126
-
127
-
128
+ @docs_group ('Classes' )
128
129
class PlatformEventManager (EventManager ):
129
130
"""A class for managing Actor events.
130
131
0 commit comments