File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -851,6 +851,9 @@ async def reboot(
851
851
custom_after_sleep = self ._configuration .metamorph_after_sleep
852
852
853
853
# Call all the listeners for the PERSIST_STATE and MIGRATING events, and wait for them to finish.
854
+ # PERSIST_STATE listeners are called to allow the Actor to persist its state before the reboot.
855
+ # MIGRATING listeners are called to allow the Actor to gracefully stop in-progress tasks before the reboot.
856
+ # Typically, crawlers are listening for the MIIGRATING event to stop processing new requests.
854
857
# We can't just emit the events and wait for all listeners to finish,
855
858
# because this method might be called from an event listener itself, and we would deadlock.
856
859
persist_state_listeners = chain .from_iterable (
You can’t perform that action at this time.
0 commit comments