def serialize()

in liminal/runners/airflow/model/task.py [0:0]

• 12 lines of code
• 1 McCabe index (conditional complexity)

    def serialize(self) -> str:
        """
        :returns: JSON string representation of this task
        """
        data = {
            'task_id': self.task_id,
            'dag': None,
            'parent': self.parent,
            'trigger_rule': self.trigger_rule,
            'liminal_config': self.liminal_config,
            'pipeline_config': self.pipeline_config,
            'task_config': self.task_config,
            'variables': self.variables,
        }

        return json.dumps(data, default=str)