diff --git a/spark_pipeline_framework/transformers/http_data_receiver/v4/test/token_service/delete_token.json b/spark_pipeline_framework/transformers/http_data_receiver/v4/test/token_service/delete_token.json new file mode 100644 index 000000000..364286a47 --- /dev/null +++ b/spark_pipeline_framework/transformers/http_data_receiver/v4/test/token_service/delete_token.json @@ -0,0 +1,11 @@ + { + "request_parameters": { + "method": "DELETE", + "headers": { + "Content-Type": "application/json", + "Authorization": "Bearer access_token" + } + }, + "request_result": { + } +} diff --git a/spark_pipeline_framework/utilities/api_helper/http_request.py b/spark_pipeline_framework/utilities/api_helper/http_request.py index e7acd4567..9d0b914ff 100644 --- a/spark_pipeline_framework/utilities/api_helper/http_request.py +++ b/spark_pipeline_framework/utilities/api_helper/http_request.py @@ -23,6 +23,7 @@ class RequestType(Enum): POST = "post" GET = "get" HEAD = "head" + DELETE = "delete" class SingleJsonResult(NamedTuple): @@ -165,6 +166,8 @@ def get_response( request_function = session.post elif self.request_type == RequestType.HEAD: request_function = session.head + elif self.request_type == RequestType.DELETE: + request_function = session.delete # remove None arguments arguments = {k: v for k, v in arguments.items() if v is not None}