@@ -1122,7 +1122,7 @@ def _get_plane_id(self, observation_id):
11221122 max_cal_level = job .get_results ()["calibrationlevel" ][0 ]
11231123 for row in job .get_results ():
11241124 if (row ["calibrationlevel" ] == max_cal_level ):
1125- planeids .append (row ["planeid" ]. decode ( 'utf-8' ) )
1125+ planeids .append (row ["planeid" ])
11261126 return planeids , max_cal_level
11271127 except Exception as e :
11281128 raise ValueError ("This observation_id does not exist in "
@@ -1206,7 +1206,7 @@ def get_related_observations(self, observation_id):
12061206 query_members = "select m.members from {} m where m.observationid" \
12071207 "='{}'" .format (self .JWST_MAIN_TABLE , observation_id )
12081208 job = self .__jwsttap .launch_job (query = query_members )
1209- oids = job .get_results ()["members" ][0 ].decode ( "utf-8" ). \
1209+ oids = job .get_results ()["members" ][0 ].\
12101210 replace ("caom:JWST/" , "" ).split (" " )
12111211 return oids
12121212
@@ -1267,12 +1267,12 @@ def _query_get_product(self, artifact_id=None, file_name=None):
12671267 query_artifactid = "select * from {} a where a.filename = " \
12681268 "'{}'" .format (self .JWST_ARTIFACT_TABLE , file_name )
12691269 job = self .__jwsttap .launch_job (query = query_artifactid )
1270- return job .get_results ()['artifactid' ][0 ]. decode ( "utf-8" )
1270+ return job .get_results ()['artifactid' ][0 ]
12711271 else :
12721272 query_filename = "select * from {} a where a.artifactid = " \
12731273 "'{}'" .format (self .JWST_ARTIFACT_TABLE , artifact_id )
12741274 job = self .__jwsttap .launch_job (query = query_filename )
1275- return job .get_results ()['filename' ][0 ]. decode ( "utf-8" )
1275+ return job .get_results ()['filename' ][0 ]
12761276
12771277 def __check_product_input (self , artifact_id , file_name ):
12781278 if artifact_id is None and file_name is None :
0 commit comments