Skip to content
Snippets Groups Projects
Select Git revision
  • b5b3c5c854fdbe1f2ffc360e66302babd7781a4b
  • master default protected
  • dither_on_off_disabled
  • yocto
  • pypcc2
  • pypcc3
  • 2020-12-07-the_only_working_copy
  • v2.1
  • v2.0
  • v1.0
  • v0.9
  • Working-RCU_ADC,ID
  • 2020-12-11-Holiday_Season_release
13 results

test_dither.py

Blame
  • Code owners
    Assign users and groups as approvers for specific file changes. Learn more.
    serializers.py 4.38 KiB
    from rest_framework import serializers
    from .models import Status, Task, Workflow, LogEntry, Configuration, Job
    
    
    
    class WorkflowSerializer(serializers.ModelSerializer):
    
        class Meta:
            model = Workflow
            fields = "__all__"
    
    
    class LogEntrySerializer(serializers.ModelSerializer):
    
        class Meta:
            model = LogEntry
            fields = "__all__"
    
    
    class TaskWriteSerializer(serializers.ModelSerializer):
    
        status_history = serializers.StringRelatedField(
            many=True,
            required=False,
        )
    
        log_entries = serializers.StringRelatedField(
            many=True,
            required=False
        )
    
        successors = serializers.StringRelatedField(
            many=True,
            required=False,
        )
    
        new_workflow_id = serializers.SerializerMethodField()  # no corresponding model property.
        new_workflow_uri = serializers.SerializerMethodField()  # no corresponding model property.
    
        class Meta:
            model = Task
            fields = ('id','task_type','filter','predecessor','successors',
                      'project','sas_id','priority','purge_policy','resume',
                      'new_workflow_id','new_workflow_uri','workflow',
                      'stage_request_id',
                      'status','new_status',
                      'inputs','outputs','metrics','status_history',
                      'size_to_process','size_processed','total_processing_time',
                      'log_entries'
                      )
    
        def get_new_workflow_id(self, instance):
            return instance.workflow.id
    
        def get_new_workflow_uri(self, instance):
            return instance.workflow.workflow_uri
    
        def create(self, validated_data):
            task = Task.objects.create(**validated_data)
    
            workflow_uri = self.initial_data['new_workflow_uri']
            if workflow_uri:
                #workflow_uri = validated_data['new_workflow_uri']
                workflow = Workflow.objects.get(workflow_uri=workflow_uri)
                task.workflow = workflow
                task.save()
                return task
    
            workflow_id = self.initial_data['new_workflow_id']
            if workflow_id:
                workflow = Workflow.objects.get(id=workflow_id)
                task.workflow = workflow
                task.save()
                return task
    
    class TaskReadSerializer(serializers.ModelSerializer):
    
        status_history = serializers.StringRelatedField(
            many=True,
            required=False,
        )
    
        log_entries = serializers.StringRelatedField(
            many=True,
            required=False
        )
    
        successors = serializers.StringRelatedField(
            many=True,
            required=False,
        )
    
        class Meta:
            model = Task
            fields = ['id','task_type','creationTime','filter','predecessor','successors',
                      'project','sas_id','priority','purge_policy','resume',
                      'workflow',
                      'stage_request_id',
                      'status','new_status',
                      'inputs','outputs','metrics','status_history',
                      'size_to_process', 'size_processed', 'total_processing_time',
                      'log_entries'
                      ]
            read_only_fields = fields
    
    
    class TaskReadSerializerFast(serializers.ModelSerializer):
        """
        status_history = serializers.StringRelatedField(
            many=True,
            required=False,
        )
    
        log_entries = serializers.StringRelatedField(
            many=True,
            required=False
        )
    
        successors = serializers.StringRelatedField(
            many=True,
            required=False,
        )
        """
        class Meta:
            model = Task
            fields = ['id','task_type','creationTime','filter','predecessor',
                      'project','sas_id','priority','purge_policy','resume',
                      'workflow',
                      'stage_request_id',
                      'status','new_status',
                      'inputs','outputs','metrics',
                      'size_to_process', 'size_processed', 'total_processing_time',
    
                      ]
            read_only_fields = fields
    
    
    class StatusSerializer(serializers.ModelSerializer):
    
        class Meta:
            model = Status
            fields = "__all__"
    
    
    class WorkflowSerializer(serializers.ModelSerializer):
    
        class Meta:
            model = Workflow
            fields = "__all__"
    
    
    class ConfigurationSerializer(serializers.ModelSerializer):
    
        class Meta:
            model = Configuration
            fields = "__all__"
    
    
    class JobSerializer(serializers.ModelSerializer):
    
        class Meta:
            model = Job
            fields = "__all__"