Differential D4697 Diff 23458 python_modules/dagster/dagster/core/events/__init__.py

Changeset View

Standalone View

python_modules/dagster/dagster/core/events/init.py

Show First 20 Lines • Show All 350 Lines • ▼ Show 20 Lines	):
def is_pipeline_event(self):		def is_pipeline_event(self):
return self.event_type in PIPELINE_EVENTS		return self.event_type in PIPELINE_EVENTS

@property		@property
def is_engine_event(self):		def is_engine_event(self):
return self.event_type == DagsterEventType.ENGINE_EVENT		return self.event_type == DagsterEventType.ENGINE_EVENT

@property		@property
		def is_external_operation_event(self):
		return (
		self.event_type_value == DagsterEventType.OBJECT_STORE_OPERATION.value
		and self.event_specific_data.op
		in (
		ObjectStoreOperationType.SET_EXTERNAL_OBJECT.value,
		ObjectStoreOperationType.GET_EXTERNAL_OBJECT.value,
		)
		)

		@property
def asset_key(self):		def asset_key(self):
if self.event_type != DagsterEventType.STEP_MATERIALIZATION:		if self.event_type != DagsterEventType.STEP_MATERIALIZATION:
return None		return None
return self.step_materialization_data.materialization.asset_key		return self.step_materialization_data.materialization.asset_key

@property		@property
def step_input_data(self):		def step_input_data(self):
_assert_type("step_input_data", DagsterEventType.STEP_INPUT, self.event_type)		_assert_type("step_input_data", DagsterEventType.STEP_INPUT, self.event_type)
▲ Show 20 Lines • Show All 408 Lines • ▼ Show 20 Lines	def object_store_operation(step_context, object_store_operation_result):

return DagsterEvent.from_step(		return DagsterEvent.from_step(
DagsterEventType.OBJECT_STORE_OPERATION,		DagsterEventType.OBJECT_STORE_OPERATION,
step_context,		step_context,
event_specific_data=ObjectStoreOperationResultData(		event_specific_data=ObjectStoreOperationResultData(
op=object_store_operation_result.op,		op=object_store_operation_result.op,
value_name=value_name,		value_name=value_name,
metadata_entries=[		metadata_entries=[
EventMetadataEntry.path(object_store_operation_result.key, label="key")		EventMetadataEntry.path(object_store_operation_result.key, label="key"),
		EventMetadataEntry.address(
		address=object_store_operation_result.address,
		label="address",
		step_output_handle=object_store_operation_result.step_output_handle,
		),
],		],
),		),
message=message,		message=message,
)		)

@staticmethod		@staticmethod
def hook_completed(hook_context, hook_def):		def hook_completed(hook_context, hook_def):
event_type = DagsterEventType.HOOK_COMPLETED		event_type = DagsterEventType.HOOK_COMPLETED
▲ Show 20 Lines • Show All 219 Lines • Show Last 20 Lines