Skip to content
Snippets Groups Projects

Resolve "release v1.4.0"

Merged Ghost User requested to merge release_v1.4.0 into master
1 file
+ 10
2
Compare changes
  • Side-by-side
  • Inline
@@ -5,11 +5,11 @@ __date__ = '2019-11-25'
@@ -5,11 +5,11 @@ __date__ = '2019-11-25'
import logging
import logging
import os
import os
 
import traceback
from typing import Tuple
from typing import Tuple
import multiprocessing
import multiprocessing
import requests
import requests
import psutil
import psutil
import traceback
import numpy as np
import numpy as np
import pandas as pd
import pandas as pd
@@ -338,6 +338,14 @@ def f_proc(data_handler, station, name_affix, store, **kwargs):
@@ -338,6 +338,14 @@ def f_proc(data_handler, station, name_affix, store, **kwargs):
res = data_handler.build(station, name_affix=name_affix, store_processed_data=store, **kwargs)
res = data_handler.build(station, name_affix=name_affix, store_processed_data=store, **kwargs)
except (AttributeError, EmptyQueryResult, KeyError, requests.ConnectionError, ValueError) as e:
except (AttributeError, EmptyQueryResult, KeyError, requests.ConnectionError, ValueError) as e:
formatted_lines = traceback.format_exc().splitlines()
formatted_lines = traceback.format_exc().splitlines()
logging.info(f"remove station {station} because it raised an error: {e} (from {' | '.join(formatted_lines[-3:])}")
logging.info(
 
f"remove station {station} because it raised an error: {e} -> {' | '.join(f_inspect_error(formatted_lines))}")
res = None
res = None
return res, station
return res, station
 
 
 
def f_inspect_error(formatted):
 
for i in range(len(formatted) - 1, -1, -1):
 
if "mlair/mlair" not in formatted[i]:
 
return formatted[i - 3:i]
 
return formatted[-3:0]
Loading