Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/core/instance/__init__.py
| Show First 20 Lines • Show All 1,049 Lines • ▼ Show 20 Lines | def has_asset_key(self, asset_key: AssetKey) -> bool: | ||||
| return self._event_storage.has_asset_key(asset_key) | return self._event_storage.has_asset_key(asset_key) | ||||
| def get_event_records( | def get_event_records( | ||||
| self, | self, | ||||
| event_records_filter: Optional["EventRecordsFilter"] = None, | event_records_filter: Optional["EventRecordsFilter"] = None, | ||||
| limit: Optional[int] = None, | limit: Optional[int] = None, | ||||
| ascending: bool = False, | ascending: bool = False, | ||||
| ) -> Iterable["EventLogRecord"]: | ) -> Iterable["EventLogRecord"]: | ||||
| """Return a list of event records stored in the event log storage. | |||||
| Args: | |||||
| event_records_filter (Optional[EventRecordsFilter]): the filter by which to filter event | |||||
| records. | |||||
| limit (Optional[int]): Number of results to get. Defaults to infinite. | |||||
| ascending (Optional[bool]): Sort the result in ascending order if True, descending | |||||
| otherwise. Defaults to descending. | |||||
| Returns: | |||||
| List[EventLogRecord]: List of event log records stored in the event log storage. | |||||
| """ | |||||
| return self._event_storage.get_event_records(event_records_filter, limit, ascending) | return self._event_storage.get_event_records(event_records_filter, limit, ascending) | ||||
| def events_for_asset_key( | def events_for_asset_key( | ||||
| self, | self, | ||||
| asset_key, | asset_key, | ||||
| partitions=None, | partitions=None, | ||||
| before_cursor=None, | before_cursor=None, | ||||
| after_cursor=None, | after_cursor=None, | ||||
| ▲ Show 20 Lines • Show All 545 Lines • Show Last 20 Lines | |||||