async def main(req: func.HttpRequest, starter: str) -> func.HttpResponse:
    """
    Start the execution.

    Args:
        req (func.HttpRequest): To get data from request body pushed by webhook

    Returns:
        func.HttpResponse: Status of Http request process (successful/failed).
    """
    __method_name = inspect.currentframe().f_code.co_name
    try:
        applogger.debug("{} HttpStarter Function Called.".format(LOGS_STARTS_WITH))
        data = get_data_from_request_body(req)
        if data:
            client = df.DurableOrchestrationClient(starter)
            if type(data) == dict:
                keys_list = [key.lower() for key in list(data)]
                if "integration-settings" in keys_list:
                    instance_id = await client.start_new(
                        req.route_params["functionName"],
                        client_input={
                            "data": data,
                            "activity": "DataminrPulseAlertsManualActivity",
                        },
                    )
                    response = await client.wait_for_completion_or_create_check_status_response(
                        req, instance_id=instance_id, timeout_in_milliseconds=1000000
                    )
                    response_body = response.get_body().decode()
                    if "Error" in response_body:
                        return func.HttpResponse(
                            body=response_body,
                            status_code=400,
                            headers={"Content-Length": str(len(response_body))},
                        )
                    else:
                        response_body = "Integration settings are added successfully with settingId={}".format(
                            response_body
                        )
                        return func.HttpResponse(
                            body=response_body,
                            status_code=200,
                            headers={"Content-Length": str(len(response_body))},
                        )
                else:
                    instance_id = await client.start_new(
                        req.route_params["functionName"],
                        client_input={
                            "data": data,
                            "activity": "DataminrPulseAlertsSentinelActivity",
                        },
                    )
                    applogger.info(f"Started orchestration with ID = '{instance_id}'.")
                    body = "Data Received successfully via Dataminr RTAP."
                    return func.HttpResponse(
                        body=body,
                        status_code=200,
                        headers={"Content-Length": str(len(body))},
                    )
            else:
                instance_id = await client.start_new(
                    req.route_params["functionName"],
                    client_input={
                        "data": data,
                        "activity": "DataminrPulseAlertsSentinelActivity",
                    },
                )
                applogger.info(f"Started orchestration with ID = '{instance_id}'.")
                body = "Data Received successfully via Dataminr RTAP."
                return func.HttpResponse(
                    body=body,
                    status_code=200,
                    headers={"Content-Length": str(len(body))},
                )
        else:
            applogger.info(
                "{}(method={})No required data found.".format(
                    LOGS_STARTS_WITH, __method_name
                )
            )
            body = "No required data found."
            return func.HttpResponse(
                body=body,
                status_code=202,
                headers={"Content-Length": str(len(body))},
            )

    except DataminrPulseException as err:
        body = "Error: {}".format(err)
        return func.HttpResponse(
            body=body,
            status_code=400,
            headers={"Content-Length": str(len(body))},
        )

    Start the execution.

    Args:
        req (func.HttpRequest): To get data from request body pushed by webhook

    Returns:
        func.HttpResponse: Status of Http request process (successful/failed).
    
Solutions/Dataminr Pulse/Data Connectors/DataminrPulseAlerts/DataminrPulseAlertsHttpStarter/__init__.py