Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/utils/test/schedule_storage.py
| Show First 20 Lines • Show All 406 Lines • ▼ Show 20 Lines | def test_add_job_with_same_name(self, storage): | ||||
| job = self.build_sensor("my_sensor") | job = self.build_sensor("my_sensor") | ||||
| storage.add_job_state(job) | storage.add_job_state(job) | ||||
| with pytest.raises(DagsterInvariantViolationError): | with pytest.raises(DagsterInvariantViolationError): | ||||
| storage.add_job_state(job) | storage.add_job_state(job) | ||||
| def build_job_tick_data( | def build_job_tick_data( | ||||
| self, | self, current_time, status=JobTickStatus.STARTED, run_id=None, error=None, run_key=None, | ||||
| current_time, | |||||
| status=JobTickStatus.STARTED, | |||||
| run_id=None, | |||||
| error=None, | |||||
| execution_key=None, | |||||
| ): | ): | ||||
| return JobTickData( | return JobTickData( | ||||
| "my_sensor", | "my_sensor", "my_sensor", JobType.SENSOR, status, current_time, run_id, error, run_key, | ||||
| "my_sensor", | |||||
| JobType.SENSOR, | |||||
| status, | |||||
| current_time, | |||||
| run_id, | |||||
| error, | |||||
| execution_key, | |||||
| ) | ) | ||||
| def test_create_job_tick(self, storage): | def test_create_job_tick(self, storage): | ||||
| assert storage | assert storage | ||||
| current_time = time.time() | current_time = time.time() | ||||
| tick = storage.create_job_tick(self.build_job_tick_data(current_time)) | tick = storage.create_job_tick(self.build_job_tick_data(current_time)) | ||||
| assert tick.tick_id == 1 | assert tick.tick_id == 1 | ||||
| ▲ Show 20 Lines • Show All 74 Lines • Show Last 20 Lines | |||||