Differential D5341 Diff 28893 python_modules/dagster/dagster/core/storage/event_log/base.py

Changeset View

Standalone View

Show First 20 Lines • Show All 112 Lines • ▼ Show 20 Lines	class AssetAwareEventLogStorage(ABC):
def has_asset_key(self, asset_key):		def has_asset_key(self, asset_key):
pass		pass

@abstractmethod		@abstractmethod
def get_all_asset_keys(self, prefix_path=None):		def get_all_asset_keys(self, prefix_path=None):
pass		pass

@abstractmethod		@abstractmethod
def get_asset_events(self, asset_key, partitions=None, cursor=None, limit=None):		def get_asset_events(
		self,
		asset_key,
		partitions=None,
		cursor=None,
		limit=None,
		ascending=False,
		include_cursor=False,
		):
pass		pass

@abstractmethod		@abstractmethod
def get_asset_run_ids(self, asset_key):		def get_asset_run_ids(self, asset_key):
pass		pass

@abstractmethod		@abstractmethod
def wipe_asset(self, asset_key):		def wipe_asset(self, asset_key):
"""Remove asset index history from event log for given asset_key"""		"""Remove asset index history from event log for given asset_key"""