27
27
28
28
from apify ._configuration import Configuration
29
29
30
-
31
30
__all__ = ['EventManager' , 'LocalEventManager' , 'PlatformEventManager' ]
32
31
33
32
34
- @docs_group ('Data structures' )
35
- class PersistStateEvent (BaseModel ):
36
- name : Literal [Event .PERSIST_STATE ]
37
- data : Annotated [EventPersistStateData , Field (default_factory = lambda : EventPersistStateData (is_migrating = False ))]
38
-
39
-
40
- @docs_group ('Data structures' )
33
+ @docs_group ('Event data' )
41
34
class SystemInfoEventData (BaseModel ):
42
35
mem_avg_bytes : Annotated [float , Field (alias = 'memAvgBytes' )]
43
36
mem_current_bytes : Annotated [float , Field (alias = 'memCurrentBytes' )]
@@ -64,31 +57,37 @@ def to_crawlee_format(self, dedicated_cpus: float) -> EventSystemInfoData:
64
57
)
65
58
66
59
67
- @docs_group ('Data structures' )
60
+ @docs_group ('Events' )
61
+ class PersistStateEvent (BaseModel ):
62
+ name : Literal [Event .PERSIST_STATE ]
63
+ data : Annotated [EventPersistStateData , Field (default_factory = lambda : EventPersistStateData (is_migrating = False ))]
64
+
65
+
66
+ @docs_group ('Events' )
68
67
class SystemInfoEvent (BaseModel ):
69
68
name : Literal [Event .SYSTEM_INFO ]
70
69
data : SystemInfoEventData
71
70
72
71
73
- @docs_group ('Data structures ' )
72
+ @docs_group ('Events ' )
74
73
class MigratingEvent (BaseModel ):
75
74
name : Literal [Event .MIGRATING ]
76
75
data : Annotated [EventMigratingData , Field (default_factory = EventMigratingData )]
77
76
78
77
79
- @docs_group ('Data structures ' )
78
+ @docs_group ('Events ' )
80
79
class AbortingEvent (BaseModel ):
81
80
name : Literal [Event .ABORTING ]
82
81
data : Annotated [EventAbortingData , Field (default_factory = EventAbortingData )]
83
82
84
83
85
- @docs_group ('Data structures ' )
84
+ @docs_group ('Events ' )
86
85
class ExitEvent (BaseModel ):
87
86
name : Literal [Event .EXIT ]
88
87
data : Annotated [EventExitData , Field (default_factory = EventExitData )]
89
88
90
89
91
- @docs_group ('Data structures ' )
90
+ @docs_group ('Events ' )
92
91
class EventWithoutData (BaseModel ):
93
92
name : Literal [
94
93
Event .SESSION_RETIRED ,
@@ -101,13 +100,13 @@ class EventWithoutData(BaseModel):
101
100
data : Any = None
102
101
103
102
104
- @docs_group ('Data structures ' )
103
+ @docs_group ('Events ' )
105
104
class DeprecatedEvent (BaseModel ):
106
105
name : Literal ['cpuInfo' ]
107
106
data : Annotated [dict [str , Any ], Field (default_factory = dict )]
108
107
109
108
110
- @docs_group ('Data structures ' )
109
+ @docs_group ('Events ' )
111
110
class UnknownEvent (BaseModel ):
112
111
name : str
113
112
data : Annotated [dict [str , Any ], Field (default_factory = dict )]
@@ -120,7 +119,7 @@ class UnknownEvent(BaseModel):
120
119
)
121
120
122
121
123
- @docs_group ('Classes ' )
122
+ @docs_group ('Event managers ' )
124
123
class PlatformEventManager (EventManager ):
125
124
"""A class for managing Actor events.
126
125
0 commit comments