@format_response
@handle_exceptions
async def create_task(self, request):
    '\n        ---\n        description: This end-point allow to test that service is up.\n        tags:\n        - Tasks\n        parameters:\n        - name: "flow_id"\n          in: "path"\n          description: "flow_id"\n          required: true\n          type: "string"\n        - name: "run_number"\n          in: "path"\n          description: "run_number"\n          required: true\n          type: "integer"\n        - name: "step_name"\n          in: "path"\n          description: "step_name"\n          required: true\n          type: "string"\n        - name: "body"\n          in: "body"\n          description: "body"\n          required: true\n          schema:\n            type: object\n            properties:\n                user_name:\n                    type: string\n                tags:\n                    type: object\n                system_tags:\n                    type: object\n        produces:\n        - \'text/plain\'\n        responses:\n            "202":\n                description: successful operation. Return newly registered task\n            "405":\n                description: invalid HTTP Method\n        '
    flow_id = request.match_info.get('flow_id')
    run_number = request.match_info.get('run_number')
    step_name = request.match_info.get('step_name')
    body = (await read_body(request.content))
    user = body.get('user_name')
    tags = body.get('tags')
    system_tags = body.get('system_tags')
    task = TaskRow(flow_id=flow_id, run_number=run_number, step_name=step_name, user_name=user, tags=tags, system_tags=system_tags)
    return (await self._async_table.add_task(task))
---
description: This end-point allow to test that service is up.
tags:
- Tasks
parameters:
- name: "flow_id"
  in: "path"
  description: "flow_id"
  required: true
  type: "string"
- name: "run_number"
  in: "path"
  description: "run_number"
  required: true
  type: "integer"
- name: "step_name"
  in: "path"
  description: "step_name"
  required: true
  type: "string"
- name: "body"
  in: "body"
  description: "body"
  required: true
  schema:
    type: object
    properties:
        user_name:
            type: string
        tags:
            type: object
        system_tags:
            type: object
produces:
- 'text/plain'
responses:
    "202":
        description: successful operation. Return newly registered task
    "405":
        description: invalid HTTP Method
@format_response
@handle_exceptions
async def create_task(self, request):
    '\n        ---\n        description: This end-point allow to test that service is up.\n        tags:\n        - Tasks\n        parameters:\n        - name: "flow_id"\n          in: "path"\n          description: "flow_id"\n          required: true\n          type: "string"\n        - name: "run_number"\n          in: "path"\n          description: "run_number"\n          required: true\n          type: "integer"\n        - name: "step_name"\n          in: "path"\n          description: "step_name"\n          required: true\n          type: "string"\n        - name: "body"\n          in: "body"\n          description: "body"\n          required: true\n          schema:\n            type: object\n            properties:\n                user_name:\n                    type: string\n                tags:\n                    type: object\n                system_tags:\n                    type: object\n        produces:\n        - \'text/plain\'\n        responses:\n            "202":\n                description: successful operation. Return newly registered task\n            "405":\n                description: invalid HTTP Method\n        '
    flow_id = request.match_info.get('flow_id')
    run_number = request.match_info.get('run_number')
    step_name = request.match_info.get('step_name')
    body = (await read_body(request.content))
    user = body.get('user_name')
    tags = body.get('tags')
    system_tags = body.get('system_tags')
    task = TaskRow(flow_id=flow_id, run_number=run_number, step_name=step_name, user_name=user, tags=tags, system_tags=system_tags)
    return (await self._async_table.add_task(task))