Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/core/storage/schedules/base.py
| Show First 20 Lines • Show All 56 Lines • ▼ Show 20 Lines | class ScheduleStorage(six.with_metaclass(abc.ABCMeta)): | ||||
| def get_job_ticks(self, job_origin_id): | def get_job_ticks(self, job_origin_id): | ||||
| """Get the ticks for a given job. | """Get the ticks for a given job. | ||||
| Args: | Args: | ||||
| job_origin_id (str): The id of the ExternalJob target | job_origin_id (str): The id of the ExternalJob target | ||||
| """ | """ | ||||
| @abc.abstractmethod | @abc.abstractmethod | ||||
| def has_job_tick(self, job_origin_id, execution_key, statuses=None): | def has_job_tick(self, job_origin_id, run_key, statuses=None): | ||||
| """Checks if there is a job tick for a given job / execution_key in storage. | """Checks if there is a job tick for a given job / run_key in storage. | ||||
| Args: | Args: | ||||
| job_origin_id (str): The id of the ExternalJob target | job_origin_id (str): The id of the ExternalJob target | ||||
| execution_key (str): User-provided key that identifies a given job execution | run_key (str): User-provided key that identifies a given job execution | ||||
| statuses (Optional[List[JobTickStatus]]): List of statuses to filter ticks by | statuses (Optional[List[JobTickStatus]]): List of statuses to filter ticks by | ||||
| """ | """ | ||||
| @abc.abstractmethod | @abc.abstractmethod | ||||
| def get_latest_job_tick(self, job_origin_id): | def get_latest_job_tick(self, job_origin_id): | ||||
| """Get the most recent tick for a given job. | """Get the most recent tick for a given job. | ||||
| Args: | Args: | ||||
| Show All 35 Lines | |||||