def processWeatherDoc()

in noaa/_tools/process.py [0:0]
71 lines of code
29 McCabe index (conditional complexity)

def processWeatherDoc(currentStationDoc):
    if 'TMAX' in currentStationDoc:
        currentStationDoc['TMAX'] = float(currentStationDoc['TMAX']) / 10.0
    if 'TMIN' in currentStationDoc:
        currentStationDoc['TMIN'] = float(currentStationDoc['TMIN']) / 10.0
    if 'PRCP' in currentStationDoc:
        currentStationDoc['PRCP'] = float(currentStationDoc['PRCP']) / 10.0
    if 'AWND' in currentStationDoc:
        currentStationDoc['AWND'] = float(currentStationDoc['AWND']) / 10.0
    if 'EVAP' in currentStationDoc:
        currentStationDoc['EVAP'] = float(currentStationDoc['EVAP']) / 10.0
    if 'MDEV' in currentStationDoc:
        currentStationDoc['MDEV'] = float(currentStationDoc['MDEV']) / 10.0
    if 'MDPR' in currentStationDoc:
        currentStationDoc['MDPR'] = float(currentStationDoc['MDPR']) / 10.0
    if 'MDTN' in currentStationDoc:
        currentStationDoc['MDTN'] = float(currentStationDoc['MDTN']) / 10.0
    if 'MDTX' in currentStationDoc:
        currentStationDoc['MDTX'] = float(currentStationDoc['MDTX']) / 10.0
    if 'MNPN' in currentStationDoc:
        currentStationDoc['MNPN'] = float(currentStationDoc['MNPN']) / 10.0
    if 'MXPN' in currentStationDoc:
        currentStationDoc['MXPN'] = float(currentStationDoc['MXPN']) / 10.0
    if 'TAVG' in currentStationDoc:
        currentStationDoc['TAVG'] = float(currentStationDoc['TAVG']) / 10.0
    if 'THIC' in currentStationDoc:
        currentStationDoc['THIC'] = float(currentStationDoc['THIC']) / 10.0
    if 'TOBS' in currentStationDoc:
        currentStationDoc['TOBS'] = float(currentStationDoc['TOBS']) / 10.0
    if 'WESD' in currentStationDoc:
        currentStationDoc['WESD'] = float(currentStationDoc['WESD']) / 10.0
    if 'WESF' in currentStationDoc:
        currentStationDoc['WESF'] = float(currentStationDoc['WESF']) / 10.0
    if 'WSF1' in currentStationDoc:
        currentStationDoc['WSF1'] = float(currentStationDoc['WSF1']) / 10.0
    if 'WSF2' in currentStationDoc:
        currentStationDoc['WSF2'] = float(currentStationDoc['WSF2']) / 10.0
    if 'WSF5' in currentStationDoc:
        currentStationDoc['WSF5'] = float(currentStationDoc['WSF5']) / 10.0
    if 'WSFG' in currentStationDoc:
        currentStationDoc['WSFG'] = float(currentStationDoc['WSFG']) / 10.0
    if 'WSFI' in currentStationDoc:
        currentStationDoc['WSFI'] = float(currentStationDoc['WSFI']) / 10.0
    if 'WSFM' in currentStationDoc:
        currentStationDoc['WSFM'] = float(currentStationDoc['WSFM']) / 10.0

    if 'TMIN' in currentStationDoc and 'TMAX' in currentStationDoc:
        if currentStationDoc['TMIN'] > currentStationDoc['TMAX']:
            tmp = currentStationDoc['TMIN']
            currentStationDoc['TMIN'] = currentStationDoc['TMAX']
            currentStationDoc['TMAX'] = tmp
        currentStationDoc['TRANGE'] = {
            "gte" : currentStationDoc['TMIN'],
            "lte" : currentStationDoc['TMAX']
        }
    if 'MDTN' in currentStationDoc and 'MDTX' in currentStationDoc:
        if currentStationDoc['MDTN'] > currentStationDoc['MDTX']:
            tmp = currentStationDoc['MDTN']
            currentStationDoc['MDTN'] = currentStationDoc['MDTX']
            currentStationDoc['MDTX'] = tmp
        currentStationDoc['MDTRANGE'] = {
            "gte" : currentStationDoc['MDTN'],
            "lte" : currentStationDoc['MDTX']
        }

    indexDoc = {
        '_op_type': 'create',
        '_index': indexPrefix + '-' + str(currentStationDoc['date'].year),
        '_type': docType,
        '_id': currentStationDoc['date'].strftime('%Y-%m-%d') + '-' + currentStationDoc['station']['id'],
        '_source': currentStationDoc
    }
    return indexDoc