Skip to content

signals#

handle_fileset_files_changed#

Source code in src/apps/core/signals.py 
20
21
22
23
24
25
26
27
28
29
30
31
@receiver(m2m_changed, sender=FileSet.files.through)
def handle_fileset_files_changed(sender, instance: FileSet, action, pk_set, **kwargs):
    if instance.skip_files_m2m_changed:  # allow skipping handler
        return
    if action == "post_add":
        instance.update_published()
    elif action == "pre_clear":
        instance.update_published(exclude_self=True)
    elif action == "pre_remove":
        instance.update_published(queryset=instance.files.filter(id__in=pk_set), exclude_self=True)
    elif action in ("post_remove", "post_clear"):
        instance.remove_unused_file_metadata()

handle_files_deleted#

Source code in src/apps/core/signals.py 
34
35
36
37
38
@receiver(pre_files_deleted, sender=File)
def handle_files_deleted(sender, queryset, **kwargs):
    fileset_ids = queryset.values_list("file_sets").order_by().distinct()
    for fileset in FileSet.all_objects.filter(id__in=fileset_ids):
        fileset.deprecate_dataset()

delete_dataset_from_v2#

Sync Metax V2 when deleting dataset from v3

Source code in src/apps/core/signals.py 
41
42
43
44
45
@receiver(post_delete, sender=Dataset)
def delete_dataset_from_v2(sender, instance: Dataset, soft=False, **kwargs):
    """Sync Metax V2 when deleting dataset from v3"""
    if settings.METAX_V2_INTEGRATION_ENABLED:
        MetaxV2Client().delete_dataset(instance, soft=soft)

handle_dataset_updated#

Source code in src/apps/core/signals.py 
48
49
50
51
52
53
54
55
56
57
58
@receiver(dataset_updated)
def handle_dataset_updated(sender, instance: Dataset, **kwargs):
    if instance.state == Dataset.StateChoices.PUBLISHED and (
        fileset := getattr(instance, "file_set", None)
    ):
        fileset.update_published()

    if settings.METAX_V2_INTEGRATION_ENABLED:
        client = MetaxV2Client()
        client.update_dataset(instance)
        client.update_dataset_files(instance)

handle_dataset_created#

Source code in src/apps/core/signals.py 
61
62
63
64
65
66
67
68
69
70
71
@receiver(dataset_created)
def handle_dataset_created(sender, instance: Dataset, **kwargs):
    if instance.state == Dataset.StateChoices.PUBLISHED and (
        fileset := getattr(instance, "file_set", None)
    ):
        fileset.update_published()

    if settings.METAX_V2_INTEGRATION_ENABLED:
        client = MetaxV2Client()
        client.update_dataset(instance, created=True)
        client.update_dataset_files(instance, created=True)

handle_dataset_pre_delete#

Source code in src/apps/core/signals.py 
74
75
76
77
78
79
@receiver(pre_delete, sender=Dataset)
def handle_dataset_pre_delete(sender, instance: Dataset, **kwargs):
    if instance.state == Dataset.StateChoices.PUBLISHED and (
        fileset := getattr(instance, "file_set", None)
    ):
        fileset.update_published(exclude_self=True)

handle_contract_sync#

Source code in src/apps/core/signals.py 
82
83
84
85
86
@receiver(sync_contract)
def handle_contract_sync(sender, instance: Contract, **kwargs):
    if settings.METAX_V2_INTEGRATION_ENABLED:
        client = MetaxV2Client()
        client.sync_contracts([instance])