Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/core/instance/__init__.py
| Show First 20 Lines • Show All 236 Lines • ▼ Show 20 Lines | ): | ||||
| self._event_storage.register_instance(self) | self._event_storage.register_instance(self) | ||||
| self._run_storage = check.inst_param(run_storage, "run_storage", RunStorage) | self._run_storage = check.inst_param(run_storage, "run_storage", RunStorage) | ||||
| self._run_storage.register_instance(self) | self._run_storage.register_instance(self) | ||||
| self._compute_log_manager = check.inst_param( | self._compute_log_manager = check.inst_param( | ||||
| compute_log_manager, "compute_log_manager", ComputeLogManager | compute_log_manager, "compute_log_manager", ComputeLogManager | ||||
| ) | ) | ||||
| self._compute_log_manager.register_instance(self) | |||||
| self._scheduler = check.opt_inst_param(scheduler, "scheduler", Scheduler) | self._scheduler = check.opt_inst_param(scheduler, "scheduler", Scheduler) | ||||
| self._schedule_storage = check.opt_inst_param( | self._schedule_storage = check.opt_inst_param( | ||||
| schedule_storage, "schedule_storage", ScheduleStorage | schedule_storage, "schedule_storage", ScheduleStorage | ||||
| ) | ) | ||||
| if self._schedule_storage: | if self._schedule_storage: | ||||
| self._schedule_storage.register_instance(self) | self._schedule_storage.register_instance(self) | ||||
| ▲ Show 20 Lines • Show All 1,309 Lines • Show Last 20 Lines | |||||