=Ki/OSrSSKJr SSKrSSKJrJr SSKJr SSKJ r SSK J r SSK J r JrJrJrJrJrJrJrJrJrJrJrJr "S S 5rg) z*Synchronous cron client for LangGraph SDK.) annotationsN)MappingSequence)datetime)Any)SyncHttpClient) AllConfigContextCronCronSelectField CronSortBy DurabilityInputOnCompletionBehaviorQueryParamTypesRun SortOrder StreamModecB\rSrSrSrSSjrSSSSSSSSSSSSSSSSSS.SSjjrSSSSSSSSSSSSSSSSSSS.SSjjrSSS .SS jjrSSSSSSSSSSSSSSSSSS .SS jjr SSSS SSSSSSS. SSjjr SSSSS.SSjjr Sr g)SyncCronClienta\Synchronous client for managing cron jobs in LangGraph. This class provides methods to create and manage scheduled tasks (cron jobs) for automated graph executions. ???+ example "Example" ```python client = get_sync_client(url="http://localhost:8123") cron_job = client.crons.create_for_thread(thread_id="thread_123", assistant_id="asst_456", schedule="0 * * * *") ``` !!! note "Feature Availability" The crons client functionality is not supported on all licenses. Please check the relevant license documentation for the most up-to-date details on feature availability. cXlg)Nhttp)self http_clients Z/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/langgraph_sdk/_sync/cron.py__init__SyncCronClient.__init__/s N)inputmetadataconfigcontextcheckpoint_duringinterrupt_beforeinterrupt_afterwebhookmultitask_strategyend_timeenabled stream_modestream_subgraphsstream_resumable durabilityheadersparamscvUb[R"S[SS9 0SU_SU_SU_SU_S U_S U_S U _S U _S U_SU _SU _SU (aU R5OS_SU_SU_SU_SU_SU_nUR 5VVs0sHunnUcM UU_M nnnUR R SUS3UUUS9$s snnf)aE Create a cron job for a thread. Args: thread_id: the thread ID to run the cron job on. assistant_id: The assistant ID or graph name to use for the cron job. If using graph name, will default to first assistant created from that graph. schedule: The cron schedule to execute this job on. Schedules are interpreted in UTC. input: The input to the graph. metadata: Metadata to assign to the cron job runs. config: The configuration for the assistant. context: Static context to add to the assistant. !!! version-added "Added in version 0.6.0" 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'. end_time: The time to stop running the cron job. If not provided, the cron job will run indefinitely. enabled: Whether the cron job is enabled. By default, it is considered enabled. stream_mode: The stream mode(s) to use. stream_subgraphs: Whether to stream output from subgraphs. stream_resumable: Whether to persist the stream chunks in order to resume the stream later. durability: Durability level for the run. Must be one of '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 headers: Optional custom headers to include with the request. Returns: The cron `Run`. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:8123") cron_run = client.crons.create_for_thread( thread_id="my-thread-id", assistant_id="agent", schedule="27 15 * * *", 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", enabled=True ) ``` Nd`checkpoint_during` is deprecated and will be removed in a future version. Use `durability` instead. stacklevelscheduler"r$r#r% assistant_idr'r(r&r)r*r+r,r-r.r/r0z /threads/ /runs/cronsjsonr1r2warningswarnDeprecationWarning isoformatitemsrpost)r thread_idr9r8r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2payloadkvs rcreate_for_thread SyncCronClient.create_for_thread2s^X  ( MMv"    U  f    w  L    0    !2  w  !"4  **,d  w  ;   0  0! " *# &%,MMOEODAqq41a4OEyy~~ {+ .   Fs = B5 B5)r"r#r$r%r&r'r(r)on_run_completedr*r+r,r-r.r/r0r1r2cvUb[R"S[SS9 0SU_SU_SU_SU_S U_S U_S U_S U _S U _SU_SU _SU _SU (aU R5OS_SU_SU_SU_SU_SU0EnUR 5VVs0sHunnUcM UU_M nnnUR R SUUUS9$s snnf)a4 Create a cron run. Args: assistant_id: The assistant ID or graph name to use for the cron job. If using graph name, will default to first assistant created from that graph. schedule: The cron schedule to execute this job on. Schedules are interpreted in UTC. input: The input to the graph. metadata: Metadata to assign to the cron job runs. config: The configuration for the assistant. context: Static context to add to the assistant. !!! version-added "Added in version 0.6.0" 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. on_run_completed: What to do with the thread after the run completes. Must be one of 'delete' (default) or 'keep'. 'delete' removes the thread after execution. 'keep' creates a new thread for each execution but does not clean them up. Clients are responsible for cleaning up kept threads. multitask_strategy: Multitask strategy to use. Must be one of 'reject', 'interrupt', 'rollback', or 'enqueue'. end_time: The time to stop running the cron job. If not provided, the cron job will run indefinitely. enabled: Whether the cron job is enabled. By default, it is considered enabled. stream_mode: The stream mode(s) to use. stream_subgraphs: Whether to stream output from subgraphs. stream_resumable: Whether to persist the stream chunks in order to resume the stream later. durability: Durability level for the run. Must be one of '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 headers: Optional custom headers to include with the request. Returns: The cron `Run`. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:8123") cron_run = client.crons.create( assistant_id="agent", schedule="27 15 * * *", input={"messages": [{"role": "user", "content": "hello!"}]}, metadata={"name":"my_run"}, context={"model_name": "openai"}, checkpoint_during=True, 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", enabled=True ) ``` Nr4r5r6r8r"r$r#r%r9r'r(r)r&rJr*r+r,r-r.r/r0r:r;r=)rr9r8r"r#r$r%r&r'r(r)rJr*r+r,r-r.r/r0r1r2rErFrGs rcreateSyncCronClient.creates_`  ( MMv"    U  f    w  L    0    w  !2   0  !"4  **,d  w  ;  0! "  0# $ *% (%,MMOEODAqq41a4OEyy~~   Fs  B5B5r1r2c>URRSU3X#S9 g)aDelete a cron. Args: cron_id: The cron ID to delete. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: `None` ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:8123") client.crons.delete( cron_id="cron_to_delete" ) ``` /runs/crons/rNN)rdelete)rcron_idr1r2s rrQSyncCronClient.deletes"6 <y17Rr!)r8r+r"r#r$r%r)r'r(rJr,r-r.r/r0r1r2cUU(aUR5OSUUUUUU U U U U UUUS.nUR5VVs0sHunnUcM UU_M nnnURRSU3UUUS9$s snnf)axUpdate a cron job by ID. Args: cron_id: The cron ID to update. schedule: The cron schedule to execute this job on. Schedules are interpreted in UTC. end_time: The end date to stop running the cron. input: The input to the graph. metadata: Metadata to assign to the cron job runs. config: The configuration for the assistant. context: Static context added to the assistant. webhook: Webhook to call after LangGraph API call is done. interrupt_before: Nodes to interrupt immediately before they get executed. interrupt_after: Nodes to interrupt immediately after they get executed. on_run_completed: What to do with the thread after the run completes. Must be one of 'delete' or 'keep'. 'delete' removes the thread after execution. 'keep' creates a new thread for each execution but does not clean them up. enabled: Enable or disable the cron job. stream_mode: The stream mode(s) to use. stream_subgraphs: Whether to stream output from subgraphs. stream_resumable: Whether to persist the stream chunks in order to resume the stream later. durability: Durability level for the run. Must be one of 'sync', 'async', or 'exit'. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: The updated cron job. ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:8123") updated_cron = client.crons.update( cron_id="1ef3cefa-4c09-6926-96d0-3dc97fd5e39b", schedule="0 10 * * *", enabled=False, ) ``` N)r8r+r"r#r$r%r)r'r(rJr,r-r.r/r0rPr;)rArBrpatch)rrRr8r+r"r#r$r%r)r'r(rJr,r-r.r/r0r1r2rErFrGs rupdateSyncCronClient.update-s@!08**,d  0. 0& 0 0$ "%,MMOEODAqq41a4OEyy7) $   Fs A4 A4 r) r9rDr,limitoffsetsort_by sort_orderselectr1r2c UUUUUS.n U(aXkS'U(aX{S'U(aXS'U R5V V s0sH upU cM X_M n n n URRSXU S9$s sn n f)aGet a list of cron jobs. Args: assistant_id: The assistant ID or graph name to search for. thread_id: the thread ID to search for. enabled: Whether the cron job is enabled. limit: The maximum number of results to return. offset: The number of results to skip. headers: Optional custom headers to include with the request. Returns: The list of cron jobs returned by the search, ???+ example "Example Usage" ```python client = get_sync_client(url="http://localhost:8123") cron_jobs = client.crons.search( assistant_id="my_assistant_id", thread_id="my_thread_id", enabled=True, limit=5, offset=5, ) print(cron_jobs) ``` ```shell ---------------------------------------------------------- [ { 'cron_id': '1ef3cefa-4c09-6926-96d0-3dc97fd5e39b', 'assistant_id': 'my_assistant_id', 'thread_id': 'my_thread_id', 'user_id': None, 'payload': { 'input': {'start_time': ''}, 'schedule': '4 * * * *', 'assistant_id': 'my_assistant_id' }, 'schedule': '4 * * * *', 'next_run_date': '2024-07-25T17:04:00+00:00', 'end_time': None, 'created_at': '2024-07-08T06:02:23.073257+00:00', 'updated_at': '2024-07-08T06:02:23.073257+00:00' } ] ``` )r9rDr,rYrZr[r\r]z/runs/crons/searchr;)rBrrC)rr9rDr,rYrZr[r\r]r1r2rErFrGs rsearchSyncCronClient.searchsD)"   !(I  $.L !  &H $+MMOEODAq414OEyy~~ w  Fs A. A.)r9rDr1r2ch0nU(aXS'U(aX%S'URRSXSUS9$)a<Count cron jobs matching filters. Args: assistant_id: Assistant ID to filter by. thread_id: Thread ID to filter by. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: int: Number of crons matching the criteria. r9rDz/runs/crons/countr;)rrC)rr9rDr1r2rEs rcountSyncCronClient.counts@&#% &2N # #,K yy~~ gv  r!r)rrreturnNone)*rDstrr9rfr8rfr" Input | Noner#Mapping[str, Any] | Noner$ Config | Noner%Context | Noner& bool | Noner'All | list[str] | Noner(rlr) str | Noner*rmr+datetime | Noner,rkr-(StreamMode | Sequence[StreamMode] | Noner.rkr/rkr0Durability | Noner1Mapping[str, str] | Noner2QueryParamTypes | Nonerdr)*r9rfr8rfr"rgr#rhr$rir%rjr&rkr'rlr(rlr)rmrJOnCompletionBehavior | Noner*rmr+rnr,rkr-ror.rkr/rkr0rpr1rqr2rrrdr)rRrfr1rqr2rrrdre)&rRrfr8rmr+rnr"rgr#rhr$rir%rjr)rmr'rlr(rlrJrsr,rkr-ror.rkr/rkr0rpr1rqr2rrrdr )r9rmrDrmr,rkrYintrZrtr[zCronSortBy | Noner\zSortOrder | Noner]zlist[CronSelectField] | Noner1rqr2rrrdz list[Cron]) r9rmrDrmr1rqr2rrrdrt) __name__ __module__ __qualname____firstlineno____doc__rrHrLrQrVr_rb__static_attributes__r!rrrs$ #-1 $"&)-3726")-$(#@D(,(,(,,0)--l l l  l  l +l l  l 'l 1l 0l l 'l "l !l ">#l $&%l &&'l (&)l **+l ,'-l . /l f#-1 $"&)-3726"8<)-$(#@D(,(,(,,0)--n n  n  n + n n  n 'n 1n 0n n 6n 'n "n !n ">#n $&%n &&'n (&)n **+n ,'-n . /n h-1)- SS* S ' S  SB $$("-1 $"&"37268<#@D(,(,(,,0)-)V V  V " V  V +V V  V V 1V 0V 6V V >V &!V "&#V $&%V &*'V (')V * +V v$( $#%)'+/3,0)-Q !Q  Q  Q  Q Q #Q %Q -Q *Q 'Q  Q l$( $,0)-  !   *  '     r!r)ry __future__rr>collections.abcrrrtypingrlanggraph_sdk._sync.httprlanggraph_sdk.schemar r r r r rrrrrrrrrr{r!rrs:0"-3"V V r!