Function get_instance_resource

apps/application/flow/tools.py:916–929

(instance, source_type, source_id, instance_field_call_dict)

def get_instance_resource(instance, source_type, source_id, instance_field_call_dict):
    response = []
    from system_manage.models.resource_mapping import ResourceMapping

    for target_type, call_list in instance_field_call_dict.items():
        target_id_list = reduce(lambda x, y: [*x, *y], [call(instance) for call in call_list], [])
        if target_id_list:
            for target_id in target_id_list:
                response.append(
                    ResourceMapping(
                        source_type=source_type, target_type=target_type, source_id=source_id, target_id=target_id
                    )
                )
    return response


def save_workflow_mapping(workflow, source_type, source_id, other_resource_mapping=None):