Differential D6214 Diff 30519 python_modules/dagster-graphql/dagster_graphql_tests/graphql/test_sensors.py
Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster-graphql/dagster_graphql_tests/graphql/test_sensors.py
| Show First 20 Lines • Show All 266 Lines • ▼ Show 20 Lines | external_repository = graphql_context.get_repository_location( | ||||
| main_repo_location_name() | main_repo_location_name() | ||||
| ).get_repository(main_repo_name()) | ).get_repository(main_repo_name()) | ||||
| graphql_context.instance.reconcile_scheduler_state(external_repository) | graphql_context.instance.reconcile_scheduler_state(external_repository) | ||||
| sensor_name = "always_no_config_sensor" | sensor_name = "always_no_config_sensor" | ||||
| external_sensor = external_repository.get_external_sensor(sensor_name) | external_sensor = external_repository.get_external_sensor(sensor_name) | ||||
| sensor_selector = infer_sensor_selector(graphql_context, sensor_name) | sensor_selector = infer_sensor_selector(graphql_context, sensor_name) | ||||
| # test with no job state | |||||
| result = execute_dagster_graphql( | |||||
| graphql_context, | |||||
| GET_SENSOR_TICK_RANGE_QUERY, | |||||
| variables={"sensorSelector": sensor_selector, "dayRange": None, "dayOffset": None}, | |||||
| ) | |||||
| assert len(result.data["sensorOrError"]["sensorState"]["ticks"]) == 0 | |||||
| # turn the sensor on | # turn the sensor on | ||||
| graphql_context.instance.add_job_state( | graphql_context.instance.add_job_state( | ||||
| JobState(external_sensor.get_external_origin(), JobType.SENSOR, JobStatus.RUNNING) | JobState(external_sensor.get_external_origin(), JobType.SENSOR, JobStatus.RUNNING) | ||||
| ) | ) | ||||
| now = pendulum.now().in_tz("US/Central") | now = pendulum.now().in_tz("US/Central") | ||||
| one = now.subtract(days=2).subtract(hours=1) | one = now.subtract(days=2).subtract(hours=1) | ||||
| with pendulum.test(one): | with pendulum.test(one): | ||||
| Show All 39 Lines | |||||