U g@s*dZddlZddlZddlZddlmZmZmZmZm Z m Z m Z m Z z(ddl Z ddlmZddlmZdZWnek rdZYnXddlmZdd lmZdd lmZdd lmZdd lmZmZererdd lm Z!ddl"m#Z#e$e%dZ&ee'ddZ(GdddeeZ)GdddeeZ dS)z2This module contains the classes JobQueue and Job.N) TYPE_CHECKINGAnyGenericOptionalTupleUnioncastoverload)AsyncIOExecutor)AsyncIOSchedulerTF) get_logger)build_repr_with_selected_attrs)JSONDict)ExtBot)CCT JobCallback)Job) ApplicationJobQueue) class_namec @seZdZdZdZdZddddZeddd Ze d dd d Z e e dd dZ e j dddZed;deddddZedeeeee je j e jfeeeeeeeeee ddd d!Zd?eeeee jfeeee je j e jfeeee je j e jfeeeeeeeeee dd" d#d$Zd@eee jeeeeeeeeeee dd% d&d'Z e!dddddfeee je"ed(feeeeeeeeee dd) d*d+Z#dAeee eeeeeeeedd,d-d.Z$ddd/d0Z%dBedd2d3d4Z&e"d5dd6d7Z'ee"d5d8d9d:Z(dS)CraThis class allows you to periodically perform tasks with the bot. It is a convenience wrapper for the APScheduler library. This class is a :class:`~typing.Generic` class and accepts one type variable that specifies the type of the argument ``context`` of the job callbacks (:paramref:`~run_once.callback`) of :meth:`run_once` and the other scheduling methods. 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]" Examples: :any:`Timer Bot ` .. 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)sunmontuewedthufrisatNreturncCs,ts tdd|_t|_tf|j|_dS)Nz\To use `JobQueue`, PTB must be installed via `pip install "python-telegram-bot[job-queue]"`.) APS_AVAILABLE RuntimeErrorrr rr scheduler_configurationrselfr(:/tmp/pip-unpacked-wheel-swnnwir2/telegram/ext/_jobqueue.py__init__dszJobQueue.__init__cCst||jdS)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 r+r&r(r(r)__repr__qs zJobQueue.__repr__3Application[Any, CCT, Any, Any, Any, JobQueue[CCT]]cCs2|jdkrtd|}|dk r&|StddS)z1The application this JobQueue is associated with.Nz)No application was set for this JobQueue.z,The application instance is no longer alive.)rr$r'r+r(r(r)r+|s  zJobQueue.applicationcCsFtj}|jr6t|jjtr6|jjjr6|jjjjp4tj}|d|j idS)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)timezoneZ executors) pytzutcr isinstancer+Zbotrdefaultstzinfor)r'r0r(r(r)r%s z JobQueue.scheduler_configurationcCstj|jjSN)datetimenowrr0r&r(r(r)_tz_nowszJobQueue._tz_nowF)time shift_dayr"cCsdSr6r(r'r:r;r(r(r)_parse_time_inputszJobQueue._parse_time_inputcCsdSr6r(r<r(r(r)r=scCs|dkr dSt|ttfr.|tj|dSt|tjrF||St|tjrtjtjj|j pj|j j d |}|j dkr|j j |}|r|tjtjkr|tjdd7}|S|S)N)seconds)tz)days)r3intfloatr9r7 timedeltar:combiner8r5rr0dateZlocalizer1r2)r'r:r; date_timer(r(r)r=s"    r+r"cCs t||_|jjf|jdS)zSet the application to be used by this JobQueue. Args: application (:class:`telegram.ext.Application`): The application. N)weakrefrefrr configurer%r.r(r(r)set_applications zJobQueue.set_applicationz JobQueue[CCT]Job[CCT]) job_queuejobr"cs||jIdHdS)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)runr+)rNrOr(r(r) job_callbackszJobQueue.job_callback)callbackwhendatanamechat_iduser_id job_kwargsr"c Csl|si}|p|j}t|||||d}|j|dd} |jj|jf|d| ||f| jpV|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. rRrTrUrVrWT)r;rF)rUtriggerZrun_dateargsr0) __name__rr=radd_jobrQr5r0_job) r'rRrSrTrUrVrWrXrOrGjr(r(r)run_onces$@   zJobQueue.run_once) rRintervalfirstlastrTrUrVrWrXr"c  Cs| si} |p|j}t|||||d} ||} ||} | rP| rP| | krPtdt|tjrd|}|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. rYz"'last' must not be before 'first'!ra)rZr[Z start_dateend_dater>rU) r\rr= ValueErrorr3r7rD total_secondsrr]rQr^)r'rRrarbrcrTrUrVrWrXrOZdt_firstZdt_lastr_r(r(r) run_repeatingFs0b     zJobQueue.run_repeating) rRrSdayrTrUrVrWrXr"c Csv|si}|p|j}t|||||d} |jj|jfd|| f||dkrFdn||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. rYcronrc)rZr[rUrhhourminutesecondr0) r\rrr]rQrkrlrmr5r0r^) r'rRrSrhrTrUrVrWrXrOr_r(r(r) run_monthlys(9    zJobQueue.run_monthly.) rRr:rArTrUrVrWrXr"c s~|si}|p|j}t|||||d} jjjf|| fddfdd|D|j|j|j|j phjj 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. rYri,csg|]}j|qSr() _CRON_MAPPING).0dr&r(r) \sz&JobQueue.run_daily..)rUr[rZZ day_of_weekrkrlrmr0) r\rrr]rQjoinrkrlrmr5r0r^) r'rRr:rArTrUrVrWrXrOr_r(r&r) run_dailys(>    zJobQueue.run_daily)rRrXrTrUrVrWr"c CsF|p|j}t|||||d}|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. rY)r[rU)r\rrr]rQr^) r'rRrXrTrUrVrWrOr_r(r(r) run_customgs ,  zJobQueue.run_customcs|jjs|jdS)z+Starts the :class:`~telegram.ext.JobQueue`.N)rrunningstartr&r(r(r)rxszJobQueue.startT)waitr"csH|rtj|jjddiIdH|jjrD|jj|dtdIdHdS)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`. Zreturn_exceptionsTN)ryg{Gz?)asyncioZgatherrZ_pending_futuresrrwshutdownsleep)r'ryr(r(r)stops  z JobQueue.stop)rM.cCstdd|jDS)zReturns a tuple of all *scheduled* jobs that are currently in the :class:`JobQueue`. Returns: Tuple[:class:`Job`]: Tuple of all *scheduled* jobs. css|]}t|VqdSr6)r from_aps_jobrqrOr(r(r) sz JobQueue.jobs..)tuplerZget_jobsr&r(r(r)jobssz JobQueue.jobs)rUr"cstfdd|DS)zReturns a tuple of all *pending/scheduled* jobs with the given name that are currently in the :class:`JobQueue`. Returns: Tuple[:class:`Job`]: Tuple of all *pending* or *scheduled* jobs matching the name. c3s|]}|jkr|VqdSr6rUrrr(r)rs z,JobQueue.get_jobs_by_name..)rr)r'rUr(rr)get_jobs_by_nameszJobQueue.get_jobs_by_name)F)F)F)NNNNN)NNNNNNN)NNNNN)NNNN)T))r\ __module__ __qualname____doc__ __slots__rpr*strr,propertyr+rr%r7r9r boolr=rrCrDr:rrL staticmethodrQrrobjectrBr`rgrn _ALL_DAYSrrurvrxr}rrr(r(r(r)r3s-   $    X   R  X 4c@s"eZdZdZdZd)eeeeee ee ee dddZ e eddd Z ee d d d Ze d ddZe d ddZedd ddZee d ddZee d ddZeje ddddZeeejd ddZeddddd Zd!dd"d#d$Zd!dd"d%d&Zdd d'd(ZdS)*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 )_enabledr^_removedrRrVrTrUrWNrYcCsLts td||_||_|p |j|_||_||_d|_d|_ t dd|_ dS)NzWTo use `Job`, PTB must be installed via `pip install "python-telegram-bot[job-queue]"`.FAPSJob) r#r$rRrTr\rUrVrWrrrr^)r'rRrTrUrVrWr(r(r)r*s z Job.__init__)itemr"c CsHzt|j|WStk rB}ztd|d|W5d}~XYnXdS)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)getattrrOAttributeError)r'rexcr(r(r) __getattr__1s zJob.__getattr__)otherr"cCst||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)r3 __class__id)r'rr(r(r)__eq__Gs  z Job.__eq__r!cCs 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. )hashrr&r(r(r)__hash__Tsz Job.__hash__cCs t||jj|j|jj|jjdS)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` )rrUrRrZ)r rOrrUrRr\rZr&r(r(r)r,]s z Job.__repr__rcCs|jS)z:class:`apscheduler.job.Job`: The APS Job this job is a wrapper for. .. versionchanged:: 20.0 This property is now read-only. )r^r&r(r(r)rOoszJob.jobcCs|jS)z3:obj:`bool`: Whether this job is due to be removed.)rr&r(r(r)removedxsz Job.removedcCs|jS)z):obj:`bool`: Whether this job is enabled.)rr&r(r(r)enabled}sz Job.enabled)statusr"cCs$|r|jn |j||_dSr6)rOresumepauser)r'rr(r(r)rs  cCs|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`. )rOZ next_run_timer&r(r(r)next_ts z Job.next_trM)aps_jobr"cCs|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` r@)r[r^)clsrZext_jobr(r(r)r~s zJob.from_aps_jobr-rHcst||IdHdS)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)rzZshield_runr.r(r(r)rPszJob.runc szzxz|jj||}Wn@tk rX}z"tjd|j|dWY WWdSd}~XYnX|IdH| |IdHWnLtk r}z.|j |j d||dd|j ddIdHW5d}~XYnXW5|j|dXdS)N)rOzEError while building CallbackContext for job %s. Job will not be run.)exc_infozJob:z:run:process_errorr) Z_mark_for_persistence_updateZ context_typescontextZfrom_job Exception_LOGGERcriticalr^Z refresh_datarRZ create_taskZ process_errorr)r'r+rrr(r(r)rs$ "zJob._runcCs|jd|_dS)z Schedules this job for removal from the :class:`JobQueue`. It will be removed without executing its callback function again. TN)rOremoverr&r(r(r)schedule_removals zJob.schedule_removal)NNNN)r\rrrrrrrrrrBr*rrrrr,rrOrrsetterr7r classmethodr~rPrrr(r(r(r)rsHB      r)*rrzr7rItypingrrrrrrrr r1Zapscheduler.executors.asyncior Zapscheduler.schedulers.asyncior r# ImportErrorZtelegram._utils.loggingr Ztelegram._utils.reprr Ztelegram._utils.typesrZtelegram.ext._extbotrZtelegram.ext._utils.typesrrZapscheduler.jobrrZ telegram.extrrrangerr\rrr(r(r(r)s:(