Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/core/instance/__init__.py
| Show First 20 Lines • Show All 927 Lines • ▼ Show 20 Lines | class DagsterInstance: | ||||
| def all_asset_keys(self, prefix_path=None): | def all_asset_keys(self, prefix_path=None): | ||||
| self.check_asset_aware() | self.check_asset_aware() | ||||
| return self._event_storage.get_all_asset_keys(prefix_path) | return self._event_storage.get_all_asset_keys(prefix_path) | ||||
| def has_asset_key(self, asset_key): | def has_asset_key(self, asset_key): | ||||
| self.check_asset_aware() | self.check_asset_aware() | ||||
| return self._event_storage.has_asset_key(asset_key) | return self._event_storage.has_asset_key(asset_key) | ||||
| def events_for_asset_key(self, asset_key, partitions=None, cursor=None, limit=None): | def events_for_asset_key( | ||||
| self, asset_key, partitions=None, cursor=None, limit=None, ascending=False | |||||
| ): | |||||
| check.inst_param(asset_key, "asset_key", AssetKey) | check.inst_param(asset_key, "asset_key", AssetKey) | ||||
| self.check_asset_aware() | self.check_asset_aware() | ||||
| return self._event_storage.get_asset_events(asset_key, partitions, cursor, limit) | return self._event_storage.get_asset_events( | ||||
| asset_key, partitions, cursor, limit, ascending=ascending, include_cursor=True | |||||
| ) | |||||
| def run_ids_for_asset_key(self, asset_key): | def run_ids_for_asset_key(self, asset_key): | ||||
| check.inst_param(asset_key, "asset_key", AssetKey) | check.inst_param(asset_key, "asset_key", AssetKey) | ||||
| self.check_asset_aware() | self.check_asset_aware() | ||||
| return self._event_storage.get_asset_run_ids(asset_key) | return self._event_storage.get_asset_run_ids(asset_key) | ||||
| def wipe_assets(self, asset_keys): | def wipe_assets(self, asset_keys): | ||||
| check.list_param(asset_keys, "asset_keys", of_type=AssetKey) | check.list_param(asset_keys, "asset_keys", of_type=AssetKey) | ||||
| ▲ Show 20 Lines • Show All 442 Lines • Show Last 20 Lines | |||||