def import_pipeline(url, pipeline_id, auth, json_payload, verify_ssl, overwrite = False):
parameters = { '<STR_LIT>' : overwrite }<EOL>import_result = requests.post(url + '<STR_LIT:/>' + pipeline_id + '<STR_LIT>', params=parameters,<EOL>headers=X_REQ_BY, auth=auth, verify=verify_ssl, json=json_payload)<EOL>if import_result.status_code != <NUM_LIT:200>:<EOL><INDENT>logging.error('<STR_LIT>' + import_result.text)<EOL><DEDENT>import_result.raise_for_status()<EOL>logging.info('<STR_LIT>')<EOL>return import_result.json()<EOL>
Import a pipeline.

    This will completely overwrite the existing pipeline.

    Args:
        url          (str): the host url in the form 'http://host:port/'.
        pipeline_id   (str): the ID of of the exported pipeline.
        auth       (tuple): a tuple of username, and password.
        json_payload (dict): the exported json payload as a dictionary.
        overwrite    (bool): overwrite existing pipeline
        verify_ssl   (bool): whether to verify ssl certificates

    Returns:
        dict: the response json