Merge pull request #400 from icanbwell/PHR-520-remove-user-agent-header-parameter

changsu-bWell · web-flow · commit def8521455f7 · 2025-06-25T15:30:17.000-04:00
PHR-520 remove user agent header parameter from fhir_sender v1, v2
diff --git a/spark_pipeline_framework/transformers/fhir_sender/v1/fhir_sender.py b/spark_pipeline_framework/transformers/fhir_sender/v1/fhir_sender.py
@@ -361,23 +361,14 @@ def _transform(self, df: DataFrame) -> DataFrame:
             assert (partition_by_column_name or num_partitions) is None
 
         if parameters and parameters.get("flow_name"):
-            user_agent_value = (
-                f"{parameters['team_name']}:helix.pipelines:{parameters['flow_name']}".replace(
-                    " ", ""
-                )
-                if parameters.get("team_name")
-                else str(parameters["flow_name"])
-            )
             if additional_request_headers:
                 additional_request_headers.update(
                     {
-                        "User-Agent": user_agent_value,
                         "Origin-Service": f"helix.pipelines:{parameters['flow_name']}",
                     }
                 )
             else:
                 additional_request_headers = {
-                    "User-Agent": user_agent_value,
                     "Origin-Service": f"helix.pipelines:{parameters['flow_name']}",
                 }
 
diff --git a/spark_pipeline_framework/transformers/fhir_sender/v2/fhir_sender.py b/spark_pipeline_framework/transformers/fhir_sender/v2/fhir_sender.py
@@ -402,23 +402,14 @@ async def _transform_async(self, df: DataFrame) -> DataFrame:
         smart_merge: Optional[bool] = self.getOrDefault(self.smart_merge)
 
         if parameters and parameters.get("flow_name"):
-            user_agent_value = (
-                f"{parameters['team_name']}:helix.pipelines:{parameters['flow_name']}".replace(
-                    " ", ""
-                )
-                if parameters.get("team_name")
-                else str(parameters["flow_name"])
-            )
             if additional_request_headers:
                 additional_request_headers.update(
                     {
-                        "User-Agent": user_agent_value,
                         "Origin-Service": f"helix.pipelines:{parameters['flow_name']}",
                     }
                 )
             else:
                 additional_request_headers = {
-                    "User-Agent": user_agent_value,
                     "Origin-Service": f"helix.pipelines:{parameters['flow_name']}",
                 }
 

Original file line number	Diff line number	Diff line change
`@@ -361,23 +361,14 @@ def _transform(self, df: DataFrame) -> DataFrame:`
`361`	`361`	`assert (partition_by_column_name or num_partitions) is None`
`362`	`362`
`363`	`363`	`if parameters and parameters.get("flow_name"):`
`364`		`- user_agent_value = (`
`365`		`- f"{parameters['team_name']}:helix.pipelines:{parameters['flow_name']}".replace(`
`366`		`- " ", ""`
`367`		`- )`
`368`		`- if parameters.get("team_name")`
`369`		`- else str(parameters["flow_name"])`
`370`		`- )`
`371`	`364`	`if additional_request_headers:`
`372`	`365`	`additional_request_headers.update(`
`373`	`366`	`{`
`374`		`- "User-Agent": user_agent_value,`
`375`	`367`	`"Origin-Service": f"helix.pipelines:{parameters['flow_name']}",`
`376`	`368`	`}`
`377`	`369`	`)`
`378`	`370`	`else:`
`379`	`371`	`additional_request_headers = {`
`380`		`- "User-Agent": user_agent_value,`
`381`	`372`	`"Origin-Service": f"helix.pipelines:{parameters['flow_name']}",`
`382`	`373`	`}`
`383`	`374`
Original file line number	Diff line number	Diff line change
`@@ -402,23 +402,14 @@ async def _transform_async(self, df: DataFrame) -> DataFrame:`
`402`	`402`	`smart_merge: Optional[bool] = self.getOrDefault(self.smart_merge)`
`403`	`403`
`404`	`404`	`if parameters and parameters.get("flow_name"):`
`405`		`- user_agent_value = (`
`406`		`- f"{parameters['team_name']}:helix.pipelines:{parameters['flow_name']}".replace(`
`407`		`- " ", ""`
`408`		`- )`
`409`		`- if parameters.get("team_name")`
`410`		`- else str(parameters["flow_name"])`
`411`		`- )`
`412`	`405`	`if additional_request_headers:`
`413`	`406`	`additional_request_headers.update(`
`414`	`407`	`{`
`415`		`- "User-Agent": user_agent_value,`
`416`	`408`	`"Origin-Service": f"helix.pipelines:{parameters['flow_name']}",`
`417`	`409`	`}`
`418`	`410`	`)`
`419`	`411`	`else:`
`420`	`412`	`additional_request_headers = {`
`421`		`- "User-Agent": user_agent_value,`
`422`	`413`	`"Origin-Service": f"helix.pipelines:{parameters['flow_name']}",`
`423`	`414`	`}`
`424`	`415`