ޠjvSrSSKJr SSKrSSKrSSKJrJrJrJ r SSK J r J r J r SSKrSSKJrJrJr SSKJr SSKJrJrJrJrJrJrJrJrJrJrJ r J!r!J"r"J#r#J$r$J%r%J&r&J'r'J(r(J)r)J*r*J+r+J,r,J-r- S S jr."S S 5r/g) z2Synchronous client for managing runs in LangGraph.) annotationsN)CallableIteratorMappingSequence)AnyLiteraloverload)_get_run_metadata_from_response_quote_path_param_sse_to_v2_dict)SyncHttpClient)AllBulkCancelRunsStatus CancelAction CheckpointCommandConfigContextDisconnectMode Durability IfNotExistsInputLangSmithTracingMultitaskStrategyOnCompletionBehaviorQueryParamTypesRun RunCreateRunCreateMetadataRunSelectField RunStatus StreamMode StreamPart StreamPartV2 StreamVersionc#p# UH,n[URUR5nUcM(Uv M. g7f)z:Wrap a raw SSE stream, converting each event to a v2 dict.N)r eventdata)rawpartv2s R/var/www/html/gaurav/venv/lib/python3.13/site-packages/langgraph_sdk/_sync/runs.py_wrap_stream_v2_syncr..s/ TZZ 3 >Hs'6 6c\rSrSrSrS0Sjr\SSSSSSSSSSSSSSSSSSSSSSSS.S1S jj5r\SSSSSSSSSSSSSSSSSSSSSSS .S2S jj5r\SSSSSSSSSSSSSSSSSSSSSSS .S3S jj5r\SSSSSSSSSSSSSSSSSSSSSS.S4Sjj5rSSSSSSSSSSSSSSSSSSSSSSSSSSS.S5Sjjr\SSSSSSSSSSSSSSSSSSSS.S6Sjj5r\SSSSSSSSSSSSSSSSSSSSSS.S7Sjj5rSSSSSSSSSSSSSSSSSSSSSSSS.S8SjjrSSS.S9Sjjr \SSSSSSSSSSSSSSSSSSSSS.S:Sjj5r \SSSSSSSSSSSSSSSSSSS.S;Sjj5r SSSSSSSSSSSSSSSSSSSSSSS.SS%jjr SS&SSS'.S?S(jjr SSSS&SSS).S@S*jjrSSS.SAS+jjrSSSSSS,.SBS-jjrSSS.SCS.jjrS/rg)DSyncRunsClient8a^Synchronous client for managing runs in LangGraph. This class provides methods to create, retrieve, and manage runs, which represent individual executions of graphs. ???+ example "Example" ```python client = get_sync_client(url="http://localhost:2024") run = client.runs.create(thread_id="thread_123", assistant_id="asst_456") ``` cXlgNhttp)selfr5s r-__init__SyncRunsClient.__init__Fs NvaluesFv1)inputcommand stream_modestream_subgraphsmetadataconfigcontext checkpoint checkpoint_idcheckpoint_duringinterrupt_beforeinterrupt_after feedback_keys on_disconnectwebhookmultitask_strategy if_not_exists after_secondslangsmith_tracingheadersparamson_run_createdversioncgr3r6 thread_id assistant_idr<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRs r-streamSyncRunsClient.streamIs: #r9)r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQcgr3rTrUs r-rXrYhs:"%r9)r<r=r>r?stream_resumabler@rArBrErFrGrHrI on_completionrLrJrMrNrOrPrQrRcgr3rTr6rVrWr<r=r>r?r[r@rArBrErFrGrHrIr\rLrJrMrNrOrPrQrRs r-rXrYs8 #r9)r<r=r>r?r[r@rArBrErFrGrHrIr\rLrJrMrNrOrPrQcgr3rTr^s r-rXrYs8"%r9)r<r=r>r?r[r@rArBrCrDrErFrGrHrIr\rJrKrLrMrNrOrPrQ durabilityrRc 4^U b[R"S[SS9 0SU_SU(a+UR5VVs0sHunnUcM UU_M snnOS_SU _SU _S U_S U_S U_S U_S U_SU_SU_SU_SU_SU _SU _SU _SU_UUUUUUS.EnUbS[ U5S3OSn SU4Sjjn!UR R U SUR5VVs0sHunnUcM UU_M snnUUT(aU!OSS9n"US:Xa [U"5$U"$s snnfs snnf)aCreate a run and stream the results. Args: thread_id: the thread ID to assign to the thread. If `None` will create a stateless run. assistant_id: The assistant ID or graph name to stream from. If using graph name, will default to first assistant created from that graph. input: The input to the graph. command: The command to execute. stream_mode: The stream mode(s) to use. stream_subgraphs: Whether to stream output from subgraphs. stream_resumable: Whether the stream is considered resumable. If true, the stream can be resumed and replayed in its entirety even after disconnection. metadata: Metadata to assign to the run. config: The configuration for the assistant. context: Static context to add to the assistant. !!! version-added "Added in version 0.6.0" checkpoint: The checkpoint to resume from. checkpoint_during: (deprecated) Whether to checkpoint during the run (or only at the end/interruption). interrupt_before: Nodes to interrupt immediately before they get executed. interrupt_after: Nodes to Nodes to interrupt immediately after they get executed. feedback_keys: Feedback keys to assign to run. on_disconnect: The disconnect mode to use. Must be one of 'cancel' or 'continue'. on_completion: Whether to delete or keep the thread created for a stateless run. Must be one of 'delete' or 'keep'. webhook: Webhook to call after LangGraph API call is done. multitask_strategy: Multitask strategy to use. Must be one of 'reject', 'interrupt', 'rollback', or 'enqueue'. if_not_exists: How to handle missing thread. Defaults to 'reject'. Must be either 'reject' (raise error if missing), or 'create' (create new thread). after_seconds: The number of seconds to wait before starting the run. Use to schedule future runs. langsmith_tracing: LangSmith tracing configuration. Allows routing traces to a specific project or associating with a dataset example. headers: Optional custom headers to include with the request. on_run_created: Optional callback to call when a run is created. durability: The durability to use for the run. Values are "sync", "async", or "exit". "async" means checkpoints are persisted async while next graph step executes, replaces checkpoint_during=True "sync" means checkpoints are persisted sync after graph step executes, replaces checkpoint_during=False "exit" means checkpoints are only persisted when the run exits, does not save intermediate steps version: Stream format version. "v1" (default) returns raw SSE StreamPart NamedTuples. "v2" returns typed dicts with `type`, `ns`, and `data` keys. Returns: Iterator of stream results. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") async for chunk in client.runs.stream( thread_id=None, assistant_id="agent", input={"messages": [{"role": "user", "content": "how are you?"}]}, stream_mode=["values","debug"], metadata={"name":"my_run"}, context={"model_name": "anthropic"}, interrupt_before=["node_to_stop_before_1","node_to_stop_before_2"], interrupt_after=["node_to_stop_after_1","node_to_stop_after_2"], feedback_keys=["my_feedback_key_1","my_feedback_key_2"], webhook="https://my.fake.webhook.com", multitask_strategy="interrupt" ): print(chunk) ``` ```shell ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------ StreamPart(event='metadata', data={'run_id': '1ef4a9b8-d7da-679a-a45a-872054341df2'}) StreamPart(event='values', data={'messages': [{'content': 'how are you?', 'additional_kwargs': {}, 'response_metadata': {}, 'type': 'human', 'name': None, 'id': 'fe0a5778-cfe9-42ee-b807-0adaa1873c10', 'example': False}]}) StreamPart(event='values', data={'messages': [{'content': 'how are you?', 'additional_kwargs': {}, 'response_metadata': {}, 'type': 'human', 'name': None, 'id': 'fe0a5778-cfe9-42ee-b807-0adaa1873c10', 'example': False}, {'content': "I'm doing well, thanks for asking! I'm an AI assistant created by Anthropic to be helpful, honest, and harmless.", 'additional_kwargs': {}, 'response_metadata': {}, 'type': 'ai', 'name': None, 'id': 'run-159b782c-b679-4830-83c6-cef87798fe8b', 'example': False, 'tool_calls': [], 'invalid_tool_calls': [], 'usage_metadata': None}]}) StreamPart(event='end', data=None) ``` Nd`checkpoint_during` is deprecated and will be removed in a future version. Use `durability` instead. stacklevelr<r=rArBr@r>r?r[rWrFrGrHrJrCrDrErK)rLrIr\rMr`langsmith_tracer /threads/z /runs/streamcL>T(a[U5=n(a T"U5 gggz)Callback function to handle the response.Nr resr@rQs r- on_response*SyncRunsClient.stream..on_responseU&/Ns/S#S8#Sx($T~r9POSTjsonrPrOrmr,rlzhttpx.Response)warningswarnDeprecationWarningitemsr r5rXr.)#r6rVrWr<r=r>r?r[r@rArBrCrDrErFrGrHrIr\rJrKrLrMrNrOrPrQr`rRkvpayloadendpointrmr*s# ` r-rXrYsV  ( MMv"  # U# GN'--/C/$!QQA/CTX# f # w #  #  ;#   0#   0#  L#   0#  #  ]#  w# *!# " ]## $ !2%# & !"4'# (+***$ 13# :$))45\ B   ) ii  #*==?D?41aa$!Q$?D'5 4   d?', , [DLEs D D  D"D)r<r=r>r?r[r@rArBrErFrGrJr\rLrMrNrOrPrQcgr3rT)r6rVrWr<r=r>r?r[r@rArBrErFrGrJr\rLrMrNrOrPrQs r-createSyncRunsClient.createfs2r9)r<r=r>r?r[r@rArBrCrDrErFrGrJrKrLrMrNrOrPrQcgr3rT)r6rVrWr<r=r>r?r[r@rArBrCrDrErFrGrJrKrLrMrNrOrPrQs r-r}r~s6r9)r<r=r>r?r[r@rArBrCrDrErFrGrJrKrLr\rMrNrOrPrQr`c^U b[R"S[SS9 0SU_SU(a+UR5VVs0sHunnUcM UU_M snnOS_SU_SU_S U_S U _S U _S U_S U_SU_SU_SU_SU _SU _SU _SU_SU_UUUUS.EnUR5VVs0sHunnUcM UU_M nnnSU4SjjnURR U(aS[ U5S3OSUUUT(aUS9$SS9$s snnfs snnf)aCreate a background run. Args: thread_id: the thread ID to assign to the thread. If `None` will create a stateless run. assistant_id: The assistant ID or graph name to stream from. If using graph name, will default to first assistant created from that graph. input: The input to the graph. command: The command to execute. stream_mode: The stream mode(s) to use. stream_subgraphs: Whether to stream output from subgraphs. stream_resumable: Whether the stream is considered resumable. If true, the stream can be resumed and replayed in its entirety even after disconnection. metadata: Metadata to assign to the run. config: The configuration for the assistant. context: Static context to add to the assistant. !!! version-added "Added in version 0.6.0" checkpoint: The checkpoint to resume from. checkpoint_during: (deprecated) Whether to checkpoint during the run (or only at the end/interruption). interrupt_before: Nodes to interrupt immediately before they get executed. interrupt_after: Nodes to Nodes to interrupt immediately after they get executed. webhook: Webhook to call after LangGraph API call is done. multitask_strategy: Multitask strategy to use. Must be one of 'reject', 'interrupt', 'rollback', or 'enqueue'. on_completion: Whether to delete or keep the thread created for a stateless run. Must be one of 'delete' or 'keep'. if_not_exists: How to handle missing thread. Defaults to 'reject'. Must be either 'reject' (raise error if missing), or 'create' (create new thread). after_seconds: The number of seconds to wait before starting the run. Use to schedule future runs. langsmith_tracing: LangSmith tracing configuration. Allows routing traces to a specific project or associating with a dataset example. headers: Optional custom headers to include with the request. on_run_created: Optional callback to call when a run is created. durability: The durability to use for the run. Values are "sync", "async", or "exit". "async" means checkpoints are persisted async while next graph step executes, replaces checkpoint_during=True "sync" means checkpoints are persisted sync after graph step executes, replaces checkpoint_during=False "exit" means checkpoints are only persisted when the run exits, does not save intermediate steps Returns: The created background `Run`. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") background_run = client.runs.create( thread_id="my_thread_id", assistant_id="my_assistant_id", input={"messages": [{"role": "user", "content": "hello!"}]}, metadata={"name":"my_run"}, context={"model_name": "openai"}, interrupt_before=["node_to_stop_before_1","node_to_stop_before_2"], interrupt_after=["node_to_stop_after_1","node_to_stop_after_2"], webhook="https://my.fake.webhook.com", multitask_strategy="interrupt" ) print(background_run) ``` ```shell -------------------------------------------------------------------------------- { 'run_id': 'my_run_id', 'thread_id': 'my_thread_id', 'assistant_id': 'my_assistant_id', 'created_at': '2024-07-25T15:35:42.598503+00:00', 'updated_at': '2024-07-25T15:35:42.598503+00:00', 'metadata': {}, 'status': 'pending', 'kwargs': { 'input': { 'messages': [ { 'role': 'user', 'content': 'how are you?' } ] }, 'config': { 'metadata': { 'created_by': 'system' }, 'configurable': { 'run_id': 'my_run_id', 'user_id': None, 'graph_id': 'agent', 'thread_id': 'my_thread_id', 'checkpoint_id': None, 'assistant_id': 'my_assistant_id' } }, 'context': { 'model_name': 'openai' }, 'webhook': "https://my.fake.webhook.com", 'temporary': False, 'stream_mode': ['values'], 'feedback_keys': None, 'interrupt_after': ["node_to_stop_after_1","node_to_stop_after_2"], 'interrupt_before': ["node_to_stop_before_1","node_to_stop_before_2"] }, 'multitask_strategy': 'interrupt' } ``` Nrbrcrdr<r=r>r?r[rArBr@rWrFrGrJrCrDrErKrL)r\rMr`rfcL>T(a[U5=n(a T"U5 gggrirjrks r-rm*SyncRunsClient.create..on_responseMror9rg/runsrqrs)rtrurvrwr5postr )r6rVrWr<r=r>r?r[r@rArBrCrDrErFrGrJrKrLr\rMrNrOrPrQr`rxryrzrms ` r-r}r~s\  ( MMv"   U GN'--/C/$!QQA/CTX ;   0    0  f  w    L   0    w  * ]! " !2# $ !"4% & ]' (+*$ 1/ 2%,MMOEODAqq41a4OE ) yy~~?Hi))45U ;g'5   <@   ;D,Fs C= C= D-DrOrPcxSSjnUVs/sH oT"U5PM nnURRSXbUS9$s snf)z,Create a batch of stateless background runs.c`UR5VVs0sH upUcM X_M snn$s snnfr3)rw)rzrxrys r-filter_payload3SyncRunsClient.create_batch..filter_payloadcs(%,]]_F_TQDAD_F FFs**z /runs/batchrrrOrP)rzr)r5r)r6payloadsrOrPrrzfiltereds r- create_batchSyncRunsClient.create_batchZsK GT(a[U5=n(a T"U5 gggrirjrks r-rm(SyncRunsClient.wait..on_response7ror9rgz /runs/waitrprqrs)rtrurvrwr r5request_reconnect)r6rVrWr<r=r@rArBrErCrDrFrGrJrIr\rKrLrMrNrrOrPrQr`rxryrzrmr{s ` r-rrsn  ( MMv"   U GN'--/C/$!QQA/CTX f  w     L   0    w  *  ]  !"4  ] ]! " !2# $ ]% & ]' ('$ 1- 2 )$))45Z @  yy**  #*==?D?41aa$!Q$?D'5 +  <@ +  ADFEs C: C:  DD r)limitoffsetstatusselectrOrPcX#S.nUbXHS'U(aXXS'U(aURU5 URRS[U5S3UUS9$)aList runs. Args: thread_id: The thread ID to list runs for. limit: The maximum number of results to return. offset: The number of results to skip. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: The runs for the thread. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") client.runs.list( thread_id="thread_id", limit=5, offset=5, ) ``` )rrrrrgrrPrO)updater5getr ) r6rVrrrrrOrP query_paramss r-listSyncRunsClient.listJsjF27'I  %+ " %+ "     'yy}}))45U ;  r9chURRS[U5S[U53UUS9$)aWGet a run. Args: thread_id: The thread ID to get. run_id: The run ID to get. headers: Optional custom headers to include with the request. Returns: `Run` object. ???+ example "Example Usage" ```python run = client.runs.get( thread_id="thread_id_to_delete", run_id="run_id_to_delete", ) ``` rg/runs/r)r5rr r6rVrun_idrOrPs r-rSyncRunsClient.getzsB:yy}}))45VrOrP last_event_idcUUS.nU(aURU5 URRS[U5S[U5S3SU0U(aSU0O0EU=(d 0E=(d SS9$) aStream output from a run in real-time, until the run is done. Output is not buffered, so any output produced before this call will not be received here. Args: thread_id: The thread ID to join. run_id: The run ID to join. stream_mode: The stream mode(s) to use. Must be a subset of the stream modes passed when creating the run. Background runs default to having the union of all stream modes. cancel_on_disconnect: Whether to cancel the run when the stream is disconnected. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. last_event_id: The last event ID to use for the stream. Returns: `None` ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:2024") client.runs.join_stream( thread_id="thread_id_to_join", run_id="run_id_to_join", stream_mode=["values", "debug"] ) ``` )r>rrgrz/streamrz Last-Event-IDNr)rr5rXr ) r6rVrrr>rOrPrrs r- join_streamSyncRunsClient.join_stream7sT'$8      'yy))45V!StreamMode | Sequence[StreamMode]r?boolr@Mapping[str, Any] | NonerA Config | NonerBContext | NonerCCheckpoint | NonerD str | NonerE bool | NonerFAll | Sequence[str] | NonerGrrHSequence[str] | NonerIDisconnectMode | NonerJrrKMultitaskStrategy | NonerLIfNotExists | NonerM int | NonerNLangSmithTracing | NonerOMapping[str, str] | NonerPQueryParamTypes | NonerQ*Callable[[RunCreateMetadata], None] | NonerR Literal['v1']rIterator[StreamPart])4rVrrWrr<rr=rr>rr?rr@rrArrBrrCrrDrrErrFrrGrrHrrIrrJrrKrrLrrMrrNrrOrrPrrQrrR Literal['v2']rIterator[StreamPartV2])2rVrrWrr<rr=rr>rr?rr[rr@rrArrBrrErrFrrGrrHrrIrr\OnCompletionBehavior | NonerLrrJrrMrrNrrOrrPrrQrrRrrr)2rVrrWrr<rr=rr>rr?rr[rr@rrArrBrrErrFrrGrrHrrIrr\rrLrrJrrMrrNrrOrrPrrQrrRrrr):rVrrWrr<rr=rr>rr?rr[rr@rrArrBrrCrrDrrErrFrrGrrHrrIrr\rrJrrKrrLrrMrrNrrOrrPrrQrr`Durability | NonerRr&rz#Iterator[StreamPart | StreamPartV2]),rVrrWrr<rr=rr>rr?rr[rr@rrArrBrrErrFrrGrrJrr\rrLrrMrrNrrOrrPrrQrrr)0rVrrWrr<rr=rr>rr?rr[rr@rrArrBrrCrrDrrErrFrrGrrJrrKrrLrrMrrNrrOrrPrrQrrr)4rVrrWrr<rr=rr>rr?rr[rr@rrArrBrrCrrDrrErrFrrGrrJrrKrrLrr\rrMrrNrrOrrPrrQrr`rrr)rzbuiltins.list[RunCreate]rOrrPrrbuiltins.list[Run]).rVrrWrr<rr=rr@rrArrBrrCrrDrrErrFrrGrrJrrIrrKrrLrrMrrNrrrrOrrPrrQrr$builtins.list[dict] | dict[str, Any])*rVrrWrr<rr=rr@rrArrBrrErrFrrGrrJrrIrr\rrLrrMrrNrrrrOrrPrrQrrr)2rVrrWrr<rr=rr@rrArrBrrErrCrrDrrFrrGrrJrrIrr\rrKrrLrrMrrNrrrrOrrPrrQrr`rrr)rVrrintrrrzRunStatus | Nonerz$builtins.list[RunSelectField] | NonerOrrPrrr) rVrrrrOrrPrrr)rVrrrrrrrrOrrPrrr)rVrrrrzBulkCancelRunsStatus | NonerrrOrrPrrr) rVrrrrOrrPrrdict)rVrrrrrr>z(StreamMode | Sequence[StreamMode] | NonerOrrPrrrrr) rVrrrrOrrPrrr)__name__ __module__ __qualname____firstlineno____doc__r7r rXr}rrrrrrrrr__static_attributes__rTr9r-r0r08s  #"&9A!&-1 $"&(,$()-7;6:.2/3"7;,0$(59,0)-EI!%7###  #  #7##+## #&#"#'#5# 4!#",##$-%#&'#(5)#**+#,"-#.3/#0*1#2'3#4C5#67#8 9##< #"&9A!&-1 $"&(,$()-7;6:.2/3"7;,0$(59,0)-EI5%%%  %  %7%%+%% %&%"%'%5% 4!%",#%$-%%&'%(5)%**+%,"-%.3/%0*1%2'3%4C5%67%8 9%%< #"&9A!&!&-1 $"&)-7;6:.2/359,0"$(59,0)-EI!%5###  #  #7###+## #'#5#4# ,!#"-##$3%#&*'#()#*"+#,3-#.*/#0'1#2C3#45#6 7##: #"&9A!&!&-1 $"&)-7;6:.2/359,0"$(59,0)-EI3%%%  %  %7%%%+%% %'%5%4% ,!%"-#%$3%%&*'%()%*"+%,3-%.*/%0'1%2C3%45%6 7%%D#"&9A!&!&-1 $"&(,$()-7;6:.2/359"7;,0$(59,0)-EI(,!%=aaa  a  a7aaa+aa a&a"a'a 5!a"4#a$,%a&-'a(3)a*+a,5-a.*/a0"1a233a4*5a6'7a8C9a:&;a<=a> -?aF #"&9A!&!&-1 $"&)-7;6:"59,0$(59,0)-EI/    7+ '54 !"3#$*%&"'(3)**+,'-.C/0 14 #"&9A!&!&-1 $"&(,$()-7;6:"7;,0$(59,0)-EI3    7+ &"' 5!"4#$%&5'(*)*"+,3-.*/0'12C34 5B#"&9A!&!&-1 $"&(,$()-7;6:"7;,059$(59,0)-EI(,7z z z  z  z 7z z z +z z  z &z "z 'z 5!z "4#z $%z &5'z (*)z *3+z ,"-z .3/z 0*1z 2'3z 4C5z 6&7z 8 9z @-1)-  * *  '    " #"&-1 $"&(,$()-7;6:"/37;,0$(59 ,0)-EI1333  3  3+33 3&3"3'353433 -!3"5#3$*%3&"'3(3)3*+3,*-3.'/30C132 .3336 #"&-1 $"&)-7;6:"/359,0$(59 ,0)-EI-333  3  3+33 3'353433-333 *!3""#3$3%3&'3(*)3*'+3,C-3. ./33<#"&-1 $"&)-(,$(7;6:"/3597;,0$(59 ,0)-EI(,5g g g  g  g +g g  g 'g &g "g 5g 4g g -!g "3#g $5%g &*'g (")g *3+g ,-g .*/g 0'1g 2C3g 4&5g 6 .7g Z#'7;,0)-. .  .  . ! . 5. *. '.  . j-1)- ! ! ! * ! ' !  ! P*,0)-8 8 8  8  8 *8 '8  8 z!%(,.2*,0)-9 9 & 9 , 9  9 *9 '9  9 @-1)- # # # * # ' #  # T&+@D,0)-$(8 8 8 # 8 > 8 *8 '8 "8  8 ~-1)- " " " * " ' "  " " r9r0)r*rrr)0r __future__rbuiltinsrtcollections.abcrrrrtypingrr r httpxlanggraph_sdk._shared.utilitiesr r r langgraph_sdk._sync.httprlanggraph_sdk.schemarrrrrrrrrrrrrrrrrr r!r"r#r$r%r&r.r0rTr9r-rss8"AA))  48 [ [ r9