idZddlZddlZddlZddlZddlmZmZm Z m Z m Z  ddl m Z ddlmZdZn #e$rdZYnwxYwddlmZmZdd lmZdd lmZdd lmZdd lmZdd lmZmZerddl m!Z!erddl"m#Z$ddl%m&Z&e'e(dZ)ee*dZ+de,de-fdZ.Gdde eZ/Gdde eZ#dS)z2This module contains the classes JobQueue and Job.N) TYPE_CHECKINGAnyGenericcastoverload)AsyncIOExecutor)AsyncIOSchedulerTF)UTClocalize) get_logger)build_repr_with_selected_attrs)JSONDict)ExtBot)CCT JobCallback)Iterable)Job) ApplicationJobQueue) class_namecallbackreturnc<t|ddp |jjS)aGet the name of a callback function or callable object. Args: callback: A callable object (function, method, or callable class instance) Returns: The name of the callback, using __name__ if available, otherwise the class name. __name__N)getattr __class__r)rs V/Users/shanyulin/my-agent/.venv/lib/python3.11/site-packages/telegram/ext/_jobqueue.py_get_callback_namer7s! 8Z . . M(2D2MMceZdZdZdZdZd3dZdefdZe d4d Z e de fd Z de jfd Zed5d ddeddfdZe d5d ee jze jze jzdede jfdZ d5d ee jze jze jzdzdede jdzfdZ d6dZed7dZ d8deedee jze jze jzdedzdedzdedzdedzde dzddfd Z d9deed!ee jzd"ee jze jze jzdzd#ee jze jze jzdzdedzdedzdedzdedzde dzddfd$Z d8deede jd%ededzdedzdedzdedzde dzddfd&Ze dddddfdeed e jd'e!ed(fdedzdedzdedzdedzde dzddfd)Z" d:deede dedzdedzdedzdedzddfd*Z#d3d+Z$d;d-eddfd.Z%d` .. seealso:: :wiki:`Architecture Overview `, :wiki:`Job Queue ` .. versionchanged:: 20.0 To use this class, PTB must be installed via ``pip install "python-telegram-bot[job-queue]"``. Attributes: scheduler (:class:`apscheduler.schedulers.asyncio.AsyncIOScheduler`): The scheduler. Warning: This scheduler is configured by :meth:`set_application`. Additional configuration settings can be made by users. However, calling :meth:`~apscheduler.schedulers.base.BaseScheduler.configure` will delete any previous configuration settings. Therefore, please make sure to pass the values returned by :attr:`scheduler_configuration` to the method call in addition to your custom values. Alternatively, you can also use methods like :meth:`~apscheduler.schedulers.base.BaseScheduler.add_jobstore` to avoid using :meth:`~apscheduler.schedulers.base.BaseScheduler.configure` altogether. .. versionchanged:: 20.0 Uses :class:`~apscheduler.schedulers.asyncio.AsyncIOScheduler` instead of :class:`~apscheduler.schedulers.background.BackgroundScheduler` ) _application _executor scheduler)sunmontuewedthufrisatrNctstdd|_t|_t di|j|_dS)Nz\To use `JobQueue`, PTB must be installed via `pip install "python-telegram-bot[job-queue]"`.) APS_AVAILABLE RuntimeErrorr"rr#r scheduler_configurationr$selfs r__init__zJobQueue.__init__ts_ 5  HL(**-=. . *. . r c.t||jS)a$Give a string representation of the JobQueue in the form ``JobQueue[application=...]``. As this class doesn't implement :meth:`object.__str__`, the default implementation will be used, which is equivalent to :meth:`__repr__`. Returns: :obj:`str` ) application)r r5r1s r__repr__zJobQueue.__repr__s.d@PQQQQr 3Application[Any, CCT, Any, Any, Any, JobQueue[CCT]]c||jtd|}||Std)z1The application this JobQueue is associated with.Nz)No application was set for this JobQueue.z,The application instance is no longer alive.)r"r/r2r5s rr5zJobQueue.applicationsH   $JKK K''))  " IJJJr ct}|jrMt|jjt r.|jjjr|jjjjpt}|d|jidS)a_Provides configuration values that are used by :class:`JobQueue` for :attr:`scheduler`. Tip: Since calling :meth:`scheduler.configure() ` deletes any previous setting, please make sure to pass these values to the method call in addition to your custom values: .. code-block:: python scheduler.configure(..., **job_queue.scheduler_configuration) Alternatively, you can also use methods like :meth:`~apscheduler.schedulers.base.BaseScheduler.add_jobstore` to avoid using :meth:`~apscheduler.schedulers.base.BaseScheduler.configure` altogether. .. versionadded:: 20.7 Returns: dict[:obj:`str`, :obj:`object`]: The configuration values as dictionary. default)timezone executors) r r" isinstancer5botrdefaultstzinfor#)r2r<s rr0z JobQueue.scheduler_configurationsx0 #   C4+/88 C $- C '+4;BsH!#T^4   r cTtj|jjSN)dtmdatetimenowr$r<r1s r_tz_nowzJobQueue._tz_nows| 7888r Ftime shift_daycdSrCr-r2rHrIs r_parse_time_inputzJobQueue._parse_time_inputsNQcr cdSrCr-rKs rrLzJobQueue._parse_time_inputs sr c|dSt|ttzr*|t j|zSt|tjr||zSt|tjrtjtj |j p |j j  |}|j t||j j }|r@|tj tkr|t jdz }|S|S)N)seconds)tz)days)r>intfloatrGrD timedeltarHrEcombinerFrAr$r<dater r )r2rHrI date_times rrLzJobQueue._parse_time_inputs- <4 dC%K ( ( @<<>>CM$$?$?$?? ? dCM * * )<<>>D( ( dCH % %  ,,   DK$J4>3J KKPPRRTXI'%Y0GHH  3Y#,*:*:3*?*???S]2222   r r5cftj||_|jjdi|jdS)zSet the application to be used by this JobQueue. Args: application (:class:`telegram.ext.Application`): The application. Nr-)weakrefrefr"r$ configurer0r9s rset_applicationzJobQueue.set_applications:$K 44  @@4#?@@@@@r job_queue JobQueue[CCT]jobJob[CCT]cJK||jd{VdS)aThis method is used as a callback for the APScheduler jobs. More precisely, the ``func`` argument of :class:`apscheduler.job.Job` is set to this method and the ``arg`` argument (representing positional arguments to ``func``) is set to a tuple containing the :class:`JobQueue` itself and the :class:`~telegram.ext.Job` instance. Tip: This method is a static method rather than a bound method. This makes the arguments more transparent and allows for easier handling of PTBs integration of APScheduler when utilizing advanced features of APScheduler. Hint: This method is effectively a wrapper for :meth:`telegram.ext.Job.run`. .. versionadded:: 20.4 Args: job_queue (:class:`JobQueue`): The job queue that created the job. job (:class:`~telegram.ext.Job`): The job to run. N)runr5)r^r`s r job_callbackzJobQueue.job_callbacks5,ggi+,,,,,,,,,,,r rwhendatanamechat_iduser_id job_kwargsc |si}|pt|}t|||||}||d} |jj|jf|d| ||f| jp |jjd|} | |_|S)a Creates a new :class:`Job` instance that runs once and adds it to the queue. Args: callback (:term:`coroutine function`): The callback function that should be executed by the new job. Callback signature:: async def callback(context: CallbackContext) when (:obj:`int` | :obj:`float` | :obj:`datetime.timedelta` | :obj:`datetime.datetime` | :obj:`datetime.time`): Time in or at which the job should run. This parameter will be interpreted depending on its type. * :obj:`int` or :obj:`float` will be interpreted as "seconds from now" in which the job should run. * :obj:`datetime.timedelta` will be interpreted as "time from now" in which the job should run. * :obj:`datetime.datetime` will be interpreted as a specific date and time at which the job should run. If the timezone (:attr:`datetime.datetime.tzinfo`) is :obj:`None`, the default timezone of the bot will be used, which is UTC unless :attr:`telegram.ext.Defaults.tzinfo` is used. * :obj:`datetime.time` will be interpreted as a specific time of day at which the job should run. This could be either today or, if the time has already passed, tomorrow. If the timezone (:attr:`datetime.time.tzinfo`) is :obj:`None`, the default timezone of the bot will be used, which is UTC unless :attr:`telegram.ext.Defaults.tzinfo` is used. chat_id (:obj:`int`, optional): Chat id of the chat associated with this job. If passed, the corresponding :attr:`~telegram.ext.CallbackContext.chat_data` will be available in the callback. .. versionadded:: 20.0 user_id (:obj:`int`, optional): User id of the user associated with this job. If passed, the corresponding :attr:`~telegram.ext.CallbackContext.user_data` will be available in the callback. .. versionadded:: 20.0 data (:obj:`object`, optional): Additional data needed for the callback function. Can be accessed through :attr:`Job.data` in the callback. Defaults to :obj:`None`. .. versionchanged:: 20.0 Renamed the parameter ``context`` to :paramref:`data`. name (:obj:`str`, optional): The name of the new job. Defaults to :external:attr:`callback.__name__ `. job_kwargs (:obj:`dict`, optional): Arbitrary keyword arguments to pass to the :meth:`apscheduler.schedulers.base.BaseScheduler.add_job()`. Returns: :class:`telegram.ext.Job`: The new :class:`Job` instance that has been added to the job queue. rrfrgrhriT)rIrW)rgtriggerrun_dateargsr<) rrrLr$add_jobrdrAr<_job) r2rrerfrgrhrirjr`rXjs rrun_oncezJobQueue.run_onces@ J3)(338$T7T[\\\**44*@@ "DN "   %@)@      r intervalfirstlastc | si} |pt|}t|||||} ||} ||} | r| r| | krtdt |t jr|}|jj |j fd|| f| | ||d| } | | _ | S)a~Creates a new :class:`Job` instance that runs at specified intervals and adds it to the queue. Note: For a note about DST, please see the documentation of `APScheduler`_. .. _`APScheduler`: https://apscheduler.readthedocs.io/en/stable/modules/triggers/cron.html #daylight-saving-time-behavior Args: callback (:term:`coroutine function`): The callback function that should be executed by the new job. Callback signature:: async def callback(context: CallbackContext) interval (:obj:`int` | :obj:`float` | :obj:`datetime.timedelta`): The interval in which the job will run. If it is an :obj:`int` or a :obj:`float`, it will be interpreted as seconds. first (:obj:`int` | :obj:`float` | :obj:`datetime.timedelta` | :obj:`datetime.datetime` | :obj:`datetime.time`, optional): Time in or at which the job should run. This parameter will be interpreted depending on its type. * :obj:`int` or :obj:`float` will be interpreted as "seconds from now" in which the job should run. * :obj:`datetime.timedelta` will be interpreted as "time from now" in which the job should run. * :obj:`datetime.datetime` will be interpreted as a specific date and time at which the job should run. If the timezone (:attr:`datetime.datetime.tzinfo`) is :obj:`None`, the default timezone of the bot will be used. * :obj:`datetime.time` will be interpreted as a specific time of day at which the job should run. This could be either today or, if the time has already passed, tomorrow. If the timezone (:attr:`datetime.time.tzinfo`) is :obj:`None`, the default timezone of the bot will be used, which is UTC unless :attr:`telegram.ext.Defaults.tzinfo` is used. Defaults to :paramref:`interval` Note: Setting :paramref:`first` to ``0``, ``datetime.datetime.now()`` or another value that indicates that the job should run immediately will not work due to how the APScheduler library works. If you want to run a job immediately, we recommend to use an approach along the lines of:: job = context.job_queue.run_repeating(callback, interval=5) await job.run(context.application) .. seealso:: :meth:`telegram.ext.Job.run` last (:obj:`int` | :obj:`float` | :obj:`datetime.timedelta` | :obj:`datetime.datetime` | :obj:`datetime.time`, optional): Latest possible time for the job to run. This parameter will be interpreted depending on its type. See :paramref:`first` for details. If :paramref:`last` is :obj:`datetime.datetime` or :obj:`datetime.time` type and ``last.tzinfo`` is :obj:`None`, the default timezone of the bot will be assumed, which is UTC unless :attr:`telegram.ext.Defaults.tzinfo` is used. Defaults to :obj:`None`. data (:obj:`object`, optional): Additional data needed for the callback function. Can be accessed through :attr:`Job.data` in the callback. Defaults to :obj:`None`. .. versionchanged:: 20.0 Renamed the parameter ``context`` to :paramref:`data`. name (:obj:`str`, optional): The name of the new job. Defaults to :external:attr:`callback.__name__ `. chat_id (:obj:`int`, optional): Chat id of the chat associated with this job. If passed, the corresponding :attr:`~telegram.ext.CallbackContext.chat_data` will be available in the callback. .. versionadded:: 20.0 user_id (:obj:`int`, optional): User id of the user associated with this job. If passed, the corresponding :attr:`~telegram.ext.CallbackContext.user_data` will be available in the callback. .. versionadded:: 20.0 job_kwargs (:obj:`dict`, optional): Arbitrary keyword arguments to pass to the :meth:`apscheduler.schedulers.base.BaseScheduler.add_job()`. Returns: :class:`telegram.ext.Job`: The new :class:`Job` instance that has been added to the job queue. rlz"'last' must not be before 'first'!rt)rmro start_dateend_daterOrg) rrrL ValueErrorr>rDrU total_secondsr$rprdrq)r2rrtrurvrfrgrhrirjr`dt_firstdt_lastrrs r run_repeatingzJobQueue.run_repeatingXsD J3)(338$T7T[\\\))%00((..  Cx CGh$6$6ABB B h . . 0--//H "DN "      r dayc |si}|pt|}t|||||} |jj|jfd|| f||dkrdn||j|j|j|jp |jj d|} | | _ | S)a Creates a new :class:`Job` that runs on a monthly basis and adds it to the queue. .. versionchanged:: 20.0 The ``day_is_strict`` argument was removed. Instead one can now pass ``-1`` to the :paramref:`day` parameter to have the job run on the last day of the month. Args: callback (:term:`coroutine function`): The callback function that should be executed by the new job. Callback signature:: async def callback(context: CallbackContext) when (:obj:`datetime.time`): Time of day at which the job should run. If the timezone (``when.tzinfo``) is :obj:`None`, the default timezone of the bot will be used, which is UTC unless :attr:`telegram.ext.Defaults.tzinfo` is used. day (:obj:`int`): Defines the day of the month whereby the job would run. It should be within the range of ``1`` and ``31``, inclusive. If a month has fewer days than this number, the job will not run in this month. Passing ``-1`` leads to the job running on the last day of the month. data (:obj:`object`, optional): Additional data needed for the callback function. Can be accessed through :attr:`Job.data` in the callback. Defaults to :obj:`None`. .. versionchanged:: 20.0 Renamed the parameter ``context`` to :paramref:`data`. name (:obj:`str`, optional): The name of the new job. Defaults to :external:attr:`callback.__name__ `. chat_id (:obj:`int`, optional): Chat id of the chat associated with this job. If passed, the corresponding :attr:`~telegram.ext.CallbackContext.chat_data` will be available in the callback. .. versionadded:: 20.0 user_id (:obj:`int`, optional): User id of the user associated with this job. If passed, the corresponding :attr:`~telegram.ext.CallbackContext.user_data` will be available in the callback. .. versionadded:: 20.0 job_kwargs (:obj:`dict`, optional): Arbitrary keyword arguments to pass to the :meth:`apscheduler.schedulers.base.BaseScheduler.add_job()`. Returns: :class:`telegram.ext.Job`: The new :class:`Job` instance that has been added to the job queue. rlcronrv)rmrorgrhourminutesecondr<) rrr$rprdrrrrAr<rq) r2rrerrfrgrhrirjr`rrs r run_monthlyzJobQueue.run_monthlysr J3)(338$T7T[\\\ "DN "   ));;[;DN$;   r rR.c ,|si}|pt|}t|||||} jjjf|| fddfd|D|j|j|j|j p jj d|} | | _ | S)a Creates a new :class:`Job` that runs on a daily basis and adds it to the queue. Note: For a note about DST, please see the documentation of `APScheduler`_. .. _`APScheduler`: https://apscheduler.readthedocs.io/en/stable/modules/triggers/cron.html #daylight-saving-time-behavior Args: callback (:term:`coroutine function`): The callback function that should be executed by the new job. Callback signature:: async def callback(context: CallbackContext) time (:obj:`datetime.time`): Time of day at which the job should run. If the timezone (:obj:`datetime.time.tzinfo`) is :obj:`None`, the default timezone of the bot will be used, which is UTC unless :attr:`telegram.ext.Defaults.tzinfo` is used. days (tuple[:obj:`int`], optional): Defines on which days of the week the job should run (where ``0-6`` correspond to sunday - saturday). By default, the job will run every day. .. versionchanged:: 20.0 Changed day of the week mapping of 0-6 from monday-sunday to sunday-saturday. data (:obj:`object`, optional): Additional data needed for the callback function. Can be accessed through :attr:`Job.data` in the callback. Defaults to :obj:`None`. .. versionchanged:: 20.0 Renamed the parameter ``context`` to :paramref:`data`. name (:obj:`str`, optional): The name of the new job. Defaults to :external:attr:`callback.__name__ `. chat_id (:obj:`int`, optional): Chat id of the chat associated with this job. If passed, the corresponding :attr:`~telegram.ext.CallbackContext.chat_data` will be available in the callback. .. versionadded:: 20.0 user_id (:obj:`int`, optional): User id of the user associated with this job. If passed, the corresponding :attr:`~telegram.ext.CallbackContext.user_data` will be available in the callback. .. versionadded:: 20.0 job_kwargs (:obj:`dict`, optional): Arbitrary keyword arguments to pass to the :meth:`apscheduler.schedulers.base.BaseScheduler.add_job()`. Returns: :class:`telegram.ext.Job`: The new :class:`Job` instance that has been added to the job queue. rlr,c*g|]}j|Sr-) _CRON_MAPPING).0dr2s r z&JobQueue.run_daily..ns!!F!F!FA$"4Q"7!F!F!Fr )rgrorm day_of_weekrrrr<) rrr$rprdjoinrrrrAr<rq) r2rrHrRrfrgrhrirjr`rrs ` r run_dailyzJobQueue.run_daily%s| J3)(338$T7T[\\\ "DN "   !F!F!F!F!F!F!FGG;;[;DN$;   r c|pt|}t|||||}|jj|jf||f|d|}||_|S)aLCreates a new custom defined :class:`Job`. Args: callback (:term:`coroutine function`): The callback function that should be executed by the new job. Callback signature:: async def callback(context: CallbackContext) job_kwargs (:obj:`dict`): Arbitrary keyword arguments. Used as arguments for :meth:`apscheduler.schedulers.base.BaseScheduler.add_job`. data (:obj:`object`, optional): Additional data needed for the callback function. Can be accessed through :attr:`Job.data` in the callback. Defaults to :obj:`None`. .. versionchanged:: 20.0 Renamed the parameter ``context`` to :paramref:`data`. name (:obj:`str`, optional): The name of the new job. Defaults to :external:attr:`callback.__name__ `. chat_id (:obj:`int`, optional): Chat id of the chat associated with this job. If passed, the corresponding :attr:`~telegram.ext.CallbackContext.chat_data` will be available in the callback. .. versionadded:: 20.0 user_id (:obj:`int`, optional): User id of the user associated with this job. If passed, the corresponding :attr:`~telegram.ext.CallbackContext.user_data` will be available in the callback. .. versionadded:: 20.0 Returns: :class:`telegram.ext.Job`: The new :class:`Job` instance that has been added to the job queue. rl)rorg)rrr$rprdrq) r2rrjrfrgrhrir`rrs r run_customzJobQueue.run_customyshX3)(338$T7T[\\\ "DN "4#4 `D#;T ` `U_ ` ` r cXK|jjs|jdSdS)z+Starts the :class:`~telegram.ext.JobQueue`.N)r$runningstartr1s rrzJobQueue.starts9~% # N " " " " " # #r TwaitcK|r!tj|jjddid{V|jjr7|j|tjdd{VdSdS)zShuts down the :class:`~telegram.ext.JobQueue`. Args: wait (:obj:`bool`, optional): Whether to wait until all currently running jobs have finished. Defaults to :obj:`True`. return_exceptionsTN)rg{Gz?)asynciogatherr#_pending_futuresr$rshutdownsleep)r2rs rstopz JobQueue.stops  .0"&        > ! & N # # # . . .-%% % % % % % % % % %  & &r pattern)ra.cd|jD}t|Stfd|DS)a%Returns a tuple of all *scheduled* jobs that are currently in the :class:`JobQueue`. Args: pattern (:obj:`str` | :obj:`re.Pattern`, optional): A regular expression pattern. If passed, only jobs whose name matches the pattern will be returned. Defaults to :obj:`None`. Hint: This uses :func:`re.search` and not :func:`re.match`. .. versionadded:: 21.10 Returns: tuple[:class:`Job`]: Tuple of all *scheduled* jobs. c3JK|]}t|VdSrC)r from_aps_job)rr`s r z JobQueue.jobs..sA) ) &)C  S ! !) ) ) ) ) ) r Nc3K|]9}|j tj|j5|V:dSrC)rgrecompilesearch)rr`rs rrz JobQueue.jobs..sb  ch ;=:g;N;N;U;UVYV^;_;_       r )r$get_jobstuple)r2rjobs_generators ` rjobsz JobQueue.jobss| ) ) -1^-D-D-F-F) ) )  ?(( (    )      r cX|dtj|dS)afReturns a tuple of all *scheduled* jobs with the given name that are currently in the :class:`JobQueue`. Hint: This method is a convenience wrapper for :meth:`jobs` with a pattern that matches the given name. Returns: tuple[:class:`Job`]: Tuple of all *scheduled* jobs matching the name. ^$)rrescape)r2rgs rget_jobs_by_namezJobQueue.get_jobs_by_names*yy/RYt__///000r rN)rr7)Fr5r7rN)r^r_r`rarN)NNNNN)NNNNNNNNNNN)TrC)*r __module__ __qualname____doc__ __slots__rr3strr6propertyr5rr0rDrErGrboolrLrTrUrHr] staticmethodrdrrobjectrSrsr~r _ALL_DAYSrrrrrrPatternrrr-r rrrCs ++Z;IEM      R# R R R RKKKXK" " " " X" H99999QQdQtQQQQXQ  cm#cl2SX=  X cm#cl2SX=D   0 AP A  A A A A---\-6#""&*RRc"Rcm#cl2SX=Rtm R Dj R t RtRtOR RRRRpIMGK"""&*}}c"}#-'}s}$s|3ch>E } cm#cl2SX=D } tm }Dj}t}t}tO} }}}}H#""&*LLc"LhL L tm L Dj LtLtLtOL LLLLd!*"""&*RRc"RhRCHo R tm R Dj RtRtRtOR RRRRp#""22c"22tm 2 Dj 2 t 2t2 2222h#### &&t&t&&&&.  C"*S/1D8 E/DZ    2 1S 1U?-C 1 1 1 1 1 1r c ~eZdZdZdZ d deededzdedzde dzde dzf d Z d ed efd Z d ed e fdZ d e fdZd efdZed!dZed e fdZed e fdZejde d dfdZed ejdzfdZed"dZ d#dZ d#dZd$dZdS)%ra This class is a convenience wrapper for the jobs held in a :class:`telegram.ext.JobQueue`. With the current backend APScheduler, :attr:`job` holds a :class:`apscheduler.job.Job` instance. Objects of this class are comparable in terms of equality. Two objects of this class are considered equal, if their :class:`id ` is equal. This class is a :class:`~typing.Generic` class and accepts one type variable that specifies the type of the argument ``context`` of :paramref:`callback`. Important: If you want to use this class, you must install PTB with the optional requirement ``job-queue``, i.e. .. code-block:: bash pip install "python-telegram-bot[job-queue]" Note: All attributes and instance methods of :attr:`job` are also directly available as attributes/methods of the corresponding :class:`telegram.ext.Job` object. Warning: This class should not be instantiated manually. Use the methods of :class:`telegram.ext.JobQueue` to schedule jobs. .. seealso:: :wiki:`Job Queue ` .. versionchanged:: 20.0 * Removed argument and attribute ``job_queue``. * Renamed ``Job.context`` to :attr:`Job.data`. * Removed argument ``job`` * To use this class, PTB must be installed via ``pip install "python-telegram-bot[job-queue]"``. Args: callback (:term:`coroutine function`): The callback function that should be executed by the new job. Callback signature:: async def callback(context: CallbackContext) data (:obj:`object`, optional): Additional data needed for the :paramref:`callback` function. Can be accessed through :attr:`Job.data` in the callback. Defaults to :obj:`None`. name (:obj:`str`, optional): The name of the new job. Defaults to :external:obj:`callback.__name__ `. chat_id (:obj:`int`, optional): Chat id of the chat that this job is associated with. .. versionadded:: 20.0 user_id (:obj:`int`, optional): User id of the user that this job is associated with. .. versionadded:: 20.0 Attributes: callback (:term:`coroutine function`): The callback function that should be executed by the new job. data (:obj:`object`): Optional. Additional data needed for the :attr:`callback` function. name (:obj:`str`): Optional. The name of the new job. chat_id (:obj:`int`): Optional. Chat id of the chat that this job is associated with. .. versionadded:: 20.0 user_id (:obj:`int`): Optional. User id of the user that this job is associated with. .. versionadded:: 20.0 )_enabledrq_removedrrhrfrgriNrrfrgrhrictstd||_||_|pt ||_||_||_d|_d|_ tdd|_ dS)NzWTo use `Job`, PTB must be installed via `pip install "python-telegram-bot[job-queue]"`.FAPSJob) r.r/rrfrrgrhrirrrrq)r2rrfrgrhris rr3z Job.__init__?sy 5  +3 #' $ D(:8(D(D #* #*   4(( r itemrcz t|j|S#t$r}td|d|d}~wwxYw)aOverrides :py:meth:`object.__getattr__` to get specific attribute of the :class:`telegram.ext.Job` object or of its attribute :class:`apscheduler.job.Job`, if exists. Args: item (:obj:`str`): The name of the attribute. Returns: :object: The value of the attribute. Raises: :exc:`AttributeError`: If the attribute does not exist in both :class:`telegram.ext.Job` and :class:`apscheduler.job.Job` objects. zDNeither 'telegram.ext.Job' nor 'apscheduler.job.Job' has attribute ''N)rr`AttributeError)r2rexcs r __getattr__zJob.__getattr__Xs\ 48T** *    ^W[^^^  s :5:othercPt||jr|j|jkSdS)aPDefines equality condition for the :class:`telegram.ext.Job` object. Two objects of this class are considered to be equal if their :class:`id ` are equal. Returns: :obj:`True` if both objects have :paramref:`id` parameters identical. :obj:`False` otherwise. F)r>rid)r2rs r__eq__z Job.__eq__ns, eT^ , , '7eh& &ur c*t|jS)zBuilds a hash value for this object such that the hash of two objects is equal if and only if the objects are equal in terms of :meth:`__eq__`. Returns: :obj:`int`: The hash value of the object. )hashrr1s r__hash__z Job.__hash__{sDG}}r ct||jj|jt |j|jjS)a>Give a string representation of the job in the form ``Job[id=..., name=..., callback=..., trigger=...]``. As this class doesn't implement :meth:`object.__str__`, the default implementation will be used, which is equivalent to :meth:`__repr__`. Returns: :obj:`str` )rrgrrm)r r`rrgrrrmr1s rr6z Job.__repr__s?. x{' 66H$     r rc|jS)z:class:`apscheduler.job.Job`: The APS Job this job is a wrapper for. .. versionchanged:: 20.0 This property is now read-only. )rqr1s rr`zJob.jobs yr c|jS)z3:obj:`bool`: Whether this job is due to be removed.)rr1s rremovedz Job.removed }r c|jS)z):obj:`bool`: Whether this job is enabled.)rr1s renabledz Job.enabledrr statusc~|r|jn|j||_dSrC)r`resumepauser)r2rs rrz Job.enableds<   HOO     HNN    r c|jjS)a :class:`datetime.datetime`: Datetime for the next job execution. Datetime is localized according to :attr:`datetime.datetime.tzinfo`. If job is removed or already ran it equals to :obj:`None`. Warning: This attribute is only available, if the :class:`telegram.ext.JobQueue` this job belongs to is already started. Otherwise APScheduler raises an :exc:`AttributeError`. )r` next_run_timer1s rnext_tz Job.next_tsx%%r aps_jobrac.|jd}||_|S)aProvides the :class:`telegram.ext.Job` that is associated with the given APScheduler job. Tip: This method can be useful when using advanced APScheduler features along with :class:`telegram.ext.JobQueue`. .. versionadded:: 20.4 Args: aps_job (:class:`apscheduler.job.Job`): The APScheduler job Returns: :class:`telegram.ext.Job` rQ)rorq)clsrext_jobs rrzJob.from_aps_jobs",q/ r r5r7cdKtj||d{VdS)aExecutes the callback function independently of the jobs schedule. Also calls :meth:`telegram.ext.Application.update_persistence`. .. versionchanged:: 20.0 Calls :meth:`telegram.ext.Application.update_persistence`. Args: application (:class:`telegram.ext.Application`): The application this job is associated with. N)rshield_runr9s rrczJob.runs<nTYY{3344444444444r cdK |jj||}nP#t$rC}td|j|Yd}~||dSd}~wwxYw|d{V| |d{VnS#t$rF}| | d||d|j dd{VYd}~nd}~wwxYw||dS#||wxYw)NzEError while building CallbackContext for job %s. Job will not be run.)exc_info)r`zJob:z:run:process_error)rg) context_typescontextfrom_job Exception_LOGGERcriticalrq_mark_for_persistence_update refresh_datar create_task process_errorr)r2r5rrs rrzJob._runs ? %3;DDT;WW     [I !   4 4 4 > > > > ># &&(( ( ( ( ( ( ( (--(( ( ( ( ( ( ( ( (   ))))$)>>7DG777*               4 4 4 > > > > >K 4 4 4 > > > >sO &B, A3"A.B,.A338B,+D, C<6rs>&98 >>>>>>>>>>>>>>======??????MMMMM32222222......??????******''''''66666666)((((((2111111(((((( E%%((OO *X* 5 5 5 N NC N N N Nk 1k 1k 1k 1k 1ws|k 1k 1k 1\QQQQQ'#,QQQQQs 1;;