@@ -78,7 +78,8 @@ def __init__(self, tap_plus_handler=None, data_handler=None):
7878 self .__jwsttap = tap_plus_handler
7979
8080 if data_handler is None :
81- self .__jwstdata = JwstDataHandler (base_url = "http://jwstdummydata.com" )
81+ self .__jwstdata = JwstDataHandler (
82+ base_url = "http://jwstdummydata.com" )
8283 # self.__jwstdata = self.__jwsttap;
8384 else :
8485 self .__jwstdata = data_handler
@@ -1036,7 +1037,7 @@ def set_token(self, token):
10361037 subcontext = 'session'
10371038 data = 'action=set&key=mast_token&value=' + token
10381039 self .__jwsttap ._TapPlus__getconnhandler ().execute_tappost (subcontext ,
1039- data )
1040+ data )
10401041
10411042 def get_product_list (self , observation_id = None ,
10421043 cal_level = "ALL" ,
@@ -1121,7 +1122,8 @@ def _get_plane_id(self, observation_id):
11211122 max_cal_level = job .get_results ()["calibrationlevel" ][0 ]
11221123 for row in job .get_results ():
11231124 if (row ["calibrationlevel" ] == max_cal_level ):
1124- planeids .append (JwstClass .get_decoded_string (row ["planeid" ]))
1125+ planeids .append (
1126+ JwstClass .get_decoded_string (row ["planeid" ]))
11251127 return planeids , max_cal_level
11261128 except Exception as e :
11271129 raise ValueError ("This observation_id does not exist in "
@@ -1205,7 +1207,8 @@ def get_related_observations(self, observation_id):
12051207 query_members = "select m.members from {} m where m.observationid" \
12061208 "='{}'" .format (self .JWST_MAIN_TABLE , observation_id )
12071209 job = self .__jwsttap .launch_job (query = query_members )
1208- oids = JwstClass .get_decoded_string (job .get_results ()["members" ][0 ]).\
1210+ oids = JwstClass .get_decoded_string (
1211+ job .get_results ()["members" ][0 ]).\
12091212 replace ("caom:JWST/" , "" ).split (" " )
12101213 return oids
12111214
@@ -1266,12 +1269,14 @@ def _query_get_product(self, artifact_id=None, file_name=None):
12661269 query_artifactid = "select * from {} a where a.filename = " \
12671270 "'{}'" .format (self .JWST_ARTIFACT_TABLE , file_name )
12681271 job = self .__jwsttap .launch_job (query = query_artifactid )
1269- return JwstClass .get_decoded_string (job .get_results ()['artifactid' ][0 ])
1272+ return JwstClass .get_decoded_string (
1273+ job .get_results ()['artifactid' ][0 ])
12701274 else :
12711275 query_filename = "select * from {} a where a.artifactid = " \
12721276 "'{}'" .format (self .JWST_ARTIFACT_TABLE , artifact_id )
12731277 job = self .__jwsttap .launch_job (query = query_filename )
1274- return JwstClass .get_decoded_string (job .get_results ()['filename' ][0 ])
1278+ return JwstClass .get_decoded_string (
1279+ job .get_results ()['filename' ][0 ])
12751280
12761281 def __check_product_input (self , artifact_id , file_name ):
12771282 if artifact_id is None and file_name is None :
@@ -1572,7 +1577,7 @@ def get_decoded_string(str):
15721577 try :
15731578 return str .decode ('utf-8' )
15741579 # return str
1575- except :
1580+ except ( UnicodeDecodeError , AttributeError ) :
15761581 return str
15771582
15781583
0 commit comments