Workflow-Engine / api /events /event_handlers /clean_when_dataset_deleted.py
Severian's picture
initial commit
a8b3f00
raw
history blame contribute delete
405 Bytes
from events.dataset_event import dataset_was_deleted
from tasks.clean_dataset_task import clean_dataset_task
@dataset_was_deleted.connect
def handle(sender, **kwargs):
dataset = sender
clean_dataset_task.delay(
dataset.id,
dataset.tenant_id,
dataset.indexing_technique,
dataset.index_struct,
dataset.collection_binding_id,
dataset.doc_form,
)