Skip to content

Commit

Permalink
correcting pylint issues
Browse files Browse the repository at this point in the history
  • Loading branch information
PhillipsOwen committed Aug 15, 2024
1 parent 410b14d commit 882b870
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 4 deletions.
5 changes: 3 additions & 2 deletions src/common/pg_impl.py
Original file line number Diff line number Diff line change
Expand Up @@ -296,7 +296,8 @@ def get_station_data(self, **kwargs) -> str:
max_forecast_endtime = (datetime.fromisoformat(kwargs['time_mark']) + timedelta(14)).isoformat()

# get forecast data
forecast_data = self.get_forecast_station_data(kwargs['station_name'], kwargs['time_mark'], max_forecast_endtime, kwargs['data_source'], kwargs['instance_name'])
forecast_data = self.get_forecast_station_data(kwargs['station_name'], kwargs['time_mark'], max_forecast_endtime, kwargs['data_source'],
kwargs['instance_name'])

# derive start date from the time mark
start_date = (datetime.fromisoformat(kwargs['time_mark']) - timedelta(4)).isoformat()
Expand Down Expand Up @@ -335,7 +336,7 @@ def get_station_data(self, **kwargs) -> str:
if not obs_data.empty:
# Check if for type of observations name and make appropriate changes
observation_name = self.get_obs_data_name(obs_data)

# Merge nowcast data with Obs data
obs_data = obs_data.merge(nowcast_data, on='time_stamp', how='outer')
else:
Expand Down
4 changes: 2 additions & 2 deletions src/server.py
Original file line number Diff line number Diff line change
Expand Up @@ -247,7 +247,7 @@ async def get_terria_map_catalog_data_secure(run_id: Union[str, None] = Query(de

try:
logger.debug(
'Input params - run_id: %s, grid_type: %s, event_type: %s, instance_name: %s, met_class: %s, storm_name: %s, cycle: %s, advisory_number: %s, '
'Params - run_id: %s, grid_type: %s, event_type: %s, instance_name: %s, met_class: %s, storm_name: %s, cycle: %s, advisory_number: %s, '
'run_date: %s, end_date: %s, project_code %s, product_type: %s, limit: %s', run_id, grid_type, event_type, instance_name, met_class,
storm_name, cycle, advisory_number, run_date, end_date, project_code, product_type, limit)

Expand All @@ -272,7 +272,7 @@ async def get_terria_map_catalog_data_secure(run_id: Union[str, None] = Query(de
# if there was a run id specified make it a wildcard
if run_id is not None:
# add in the new workbench retrieval flag
#kwargs.update({'use_new_wb': False})
# kwargs.update({'use_new_wb': False})
kwargs.update({'run_id': run_id + '%'})

# try to make the call for records
Expand Down

0 comments on commit 882b870

Please sign in to comment.