ufpy update from master_17.1.1p2
This commit is contained in:
parent
3359f39cae
commit
a0a5d53251
44 changed files with 149 additions and 224 deletions
|
@ -2,7 +2,6 @@
|
|||
# File auto-generated by PythonFileGenerator
|
||||
|
||||
__all__ = [
|
||||
'atcf',
|
||||
'gempak',
|
||||
'gpd',
|
||||
'pgen'
|
||||
|
|
|
@ -1,59 +1,17 @@
|
|||
|
||||
# File auto-generated against equivalent DynamicSerialize Java class
|
||||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# Sep 16, 2016 pmoyer Generated
|
||||
|
||||
class GetGridDataRequest(object):
|
||||
|
||||
def __init__(self):
|
||||
self.vcoord = None
|
||||
self.level2 = None
|
||||
self.modelId = None
|
||||
self.parm = None
|
||||
self.level1 = None
|
||||
self.reftime = None
|
||||
self.pluginName = None
|
||||
self.modelId = None
|
||||
self.reftime = None
|
||||
self.fcstsec = None
|
||||
|
||||
def getVcoord(self):
|
||||
return self.vcoord
|
||||
|
||||
def setVcoord(self, vcoord):
|
||||
self.vcoord = vcoord
|
||||
|
||||
def getLevel2(self):
|
||||
return self.level2
|
||||
|
||||
def setLevel2(self, level2):
|
||||
self.level2 = level2
|
||||
|
||||
def getModelId(self):
|
||||
return self.modelId
|
||||
|
||||
def setModelId(self, modelId):
|
||||
self.modelId = modelId
|
||||
|
||||
def getParm(self):
|
||||
return self.parm
|
||||
|
||||
def setParm(self, parm):
|
||||
self.parm = parm
|
||||
|
||||
def getLevel1(self):
|
||||
return self.level1
|
||||
|
||||
def setLevel1(self, level1):
|
||||
self.level1 = level1
|
||||
|
||||
def getReftime(self):
|
||||
return self.reftime
|
||||
|
||||
def setReftime(self, reftime):
|
||||
self.reftime = reftime
|
||||
self.level1 = None
|
||||
self.level2 = None
|
||||
self.vcoord = None
|
||||
self.parm = None
|
||||
|
||||
def getPluginName(self):
|
||||
return self.pluginName
|
||||
|
@ -61,9 +19,44 @@ class GetGridDataRequest(object):
|
|||
def setPluginName(self, pluginName):
|
||||
self.pluginName = pluginName
|
||||
|
||||
def getModelId(self):
|
||||
return self.modelId
|
||||
|
||||
def setModelId(self, modelId):
|
||||
self.modelId = modelId
|
||||
|
||||
def getReftime(self):
|
||||
return self.reftime
|
||||
|
||||
def setReftime(self, reftime):
|
||||
self.reftime = reftime
|
||||
|
||||
def getFcstsec(self):
|
||||
return self.fcstsec
|
||||
|
||||
def setFcstsec(self, fcstsec):
|
||||
def setFcstSec(self, fcstsec):
|
||||
self.fcstsec = fcstsec
|
||||
|
||||
def getLevel1(self):
|
||||
return self.level1
|
||||
|
||||
def setLevel1(self, level1):
|
||||
self.level1 = level1
|
||||
|
||||
def getLevel2(self):
|
||||
return self.level2
|
||||
|
||||
def setLevel2(self, level2):
|
||||
self.level2 = level2
|
||||
|
||||
def getVcoord(self):
|
||||
return self.vcoord
|
||||
|
||||
def setVcoord(self, vcoord):
|
||||
self.vcoord = vcoord
|
||||
|
||||
def getParm(self):
|
||||
return self.parm
|
||||
|
||||
def setParm(self, parm):
|
||||
self.parm = parm
|
||||
|
|
|
@ -1,31 +1,11 @@
|
|||
|
||||
# File auto-generated against equivalent DynamicSerialize Java class
|
||||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# Sep 16, 2016 pmoyer Generated
|
||||
|
||||
class GetGridInfoRequest(object):
|
||||
|
||||
def __init__(self):
|
||||
self.modelId = None
|
||||
self.reftime = None
|
||||
self.pluginName = None
|
||||
self.fcstsec = None
|
||||
|
||||
def getModelId(self):
|
||||
return self.modelId
|
||||
|
||||
def setModelId(self, modelId):
|
||||
self.modelId = modelId
|
||||
|
||||
def getReftime(self):
|
||||
return self.reftime
|
||||
|
||||
def setReftime(self, reftime):
|
||||
self.reftime = reftime
|
||||
self.modelId = None
|
||||
|
||||
def getPluginName(self):
|
||||
return self.pluginName
|
||||
|
@ -33,9 +13,9 @@ class GetGridInfoRequest(object):
|
|||
def setPluginName(self, pluginName):
|
||||
self.pluginName = pluginName
|
||||
|
||||
def getFcstsec(self):
|
||||
return self.fcstsec
|
||||
def getModelId(self):
|
||||
return self.modelId
|
||||
|
||||
def setFcstsec(self, fcstsec):
|
||||
self.fcstsec = fcstsec
|
||||
def setModelId(self, modelId):
|
||||
self.modelId = modelId
|
||||
|
||||
|
|
|
@ -1,23 +1,11 @@
|
|||
|
||||
# File auto-generated against equivalent DynamicSerialize Java class
|
||||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# Sep 16, 2016 pmoyer Generated
|
||||
|
||||
class GetGridNavRequest(object):
|
||||
|
||||
def __init__(self):
|
||||
self.modelId = None
|
||||
self.pluginName = None
|
||||
|
||||
def getModelId(self):
|
||||
return self.modelId
|
||||
|
||||
def setModelId(self, modelId):
|
||||
self.modelId = modelId
|
||||
self.modelId = None
|
||||
|
||||
def getPluginName(self):
|
||||
return self.pluginName
|
||||
|
@ -25,3 +13,9 @@ class GetGridNavRequest(object):
|
|||
def setPluginName(self, pluginName):
|
||||
self.pluginName = pluginName
|
||||
|
||||
def getModelId(self):
|
||||
return self.modelId
|
||||
|
||||
def setModelId(self, modelId):
|
||||
self.modelId = modelId
|
||||
|
||||
|
|
|
@ -1,11 +1,5 @@
|
|||
|
||||
# File auto-generated against equivalent DynamicSerialize Java class
|
||||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# Sep 16, 2016 pmoyer Generated
|
||||
|
||||
class GetStationsRequest(object):
|
||||
|
||||
|
@ -17,4 +11,3 @@ class GetStationsRequest(object):
|
|||
|
||||
def setPluginName(self, pluginName):
|
||||
self.pluginName = pluginName
|
||||
|
||||
|
|
|
@ -1,11 +1,5 @@
|
|||
|
||||
# File auto-generated against equivalent DynamicSerialize Java class
|
||||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# Sep 16, 2016 pmoyer Generated
|
||||
|
||||
class GetTimesRequest(object):
|
||||
|
||||
|
|
|
@ -1,11 +1,5 @@
|
|||
|
||||
# File auto-generated against equivalent DynamicSerialize Java class
|
||||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# Sep 16, 2016 pmoyer Generated
|
||||
|
||||
class GetTimesResponse(object):
|
||||
|
||||
|
|
|
@ -1,36 +1,16 @@
|
|||
|
||||
# File auto-generated against equivalent DynamicSerialize Java class
|
||||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# Sep 16, 2016 pmoyer Generated
|
||||
|
||||
import numpy
|
||||
|
||||
class Station(object):
|
||||
|
||||
def __init__(self):
|
||||
self.elevation = None
|
||||
self.state = None
|
||||
self.stationId = None
|
||||
self.longitude = None
|
||||
self.latitude = None
|
||||
self.wmoIndex = None
|
||||
self.elevation = None
|
||||
self.country = None
|
||||
|
||||
def getElevation(self):
|
||||
return self.elevation
|
||||
|
||||
def setElevation(self, elevation):
|
||||
self.elevation = elevation
|
||||
|
||||
def getState(self):
|
||||
return self.state
|
||||
|
||||
def setState(self, state):
|
||||
self.state = state
|
||||
self.state = None
|
||||
self.latitude = None
|
||||
self.longitude = None
|
||||
|
||||
def getStationId(self):
|
||||
return self.stationId
|
||||
|
@ -38,27 +18,39 @@ class Station(object):
|
|||
def setStationId(self, stationId):
|
||||
self.stationId = stationId
|
||||
|
||||
def getLongitude(self):
|
||||
return self.longitude
|
||||
|
||||
def setLongitude(self, longitude):
|
||||
self.longitude = numpy.float64(longitude)
|
||||
|
||||
def getLatitude(self):
|
||||
return self.latitude
|
||||
|
||||
def setLatitude(self, latitude):
|
||||
self.latitude = numpy.float64(latitude)
|
||||
|
||||
def getWmoIndex(self):
|
||||
return self.wmoIndex
|
||||
|
||||
def setWmoIndex(self, wmoIndex):
|
||||
self.wmoIndex = wmoIndex
|
||||
|
||||
def getElevation(self):
|
||||
return self.elevation
|
||||
|
||||
def setElevation(self, elevation):
|
||||
self.elevation = elevation
|
||||
|
||||
def getCountry(self):
|
||||
return self.country
|
||||
|
||||
def setCountry(self, country):
|
||||
self.country = country
|
||||
|
||||
def getState(self):
|
||||
return self.state
|
||||
|
||||
def setState(self, state):
|
||||
self.state = state
|
||||
|
||||
def getLatitude(self):
|
||||
return self.latitude
|
||||
|
||||
def setLatitude(self, latitude):
|
||||
self.latitude = latitude
|
||||
|
||||
def getLongitude(self):
|
||||
return self.longitude
|
||||
|
||||
def setLongitude(self, longitude):
|
||||
self.longitude = longitude
|
||||
|
||||
|
|
|
@ -1,45 +1,39 @@
|
|||
|
||||
# File auto-generated against equivalent DynamicSerialize Java class
|
||||
#
|
||||
# SOFTWARE HISTORY
|
||||
#
|
||||
# Date Ticket# Engineer Description
|
||||
# ------------ ---------- ----------- --------------------------
|
||||
# Sep 16, 2016 pmoyer Generated
|
||||
|
||||
class StationDataRequest(object):
|
||||
|
||||
def __init__(self):
|
||||
self.refTime = None
|
||||
self.pluginName = None
|
||||
self.parmList = None
|
||||
self.stationId = None
|
||||
self.refTime = None
|
||||
self.parmList = None
|
||||
self.partNumber = None
|
||||
|
||||
def getRefTime(self):
|
||||
return self.refTime
|
||||
|
||||
def setRefTime(self, refTime):
|
||||
self.refTime = refTime
|
||||
|
||||
def getPluginName(self):
|
||||
return self.pluginName
|
||||
|
||||
def setPluginName(self, pluginName):
|
||||
self.pluginName = pluginName
|
||||
|
||||
def getParmList(self):
|
||||
return self.parmList
|
||||
|
||||
def setParmList(self, parmList):
|
||||
self.parmList = parmList
|
||||
|
||||
def getStationId(self):
|
||||
return self.stationId
|
||||
|
||||
def setStationId(self, stationId):
|
||||
self.stationId = stationId
|
||||
|
||||
def getRefTime(self):
|
||||
return self.refTime
|
||||
|
||||
def setRefTime(self, refTime):
|
||||
self.refTime = refTime
|
||||
|
||||
def getParmList(self):
|
||||
return self.parmList
|
||||
|
||||
def setParmList(self, parmList):
|
||||
self.parmList = parmList
|
||||
|
||||
def getPartNumber(self):
|
||||
return self.partNumber
|
||||
|
||||
|
|
|
@ -2,26 +2,21 @@
|
|||
# File auto-generated by PythonFileGenerator
|
||||
|
||||
__all__ = [
|
||||
'GetGridDataRequest',
|
||||
'GetGridInfoRequest',
|
||||
'GetGridNavRequest',
|
||||
'GetStationsRequest',
|
||||
'GetTimesRequest',
|
||||
'GetStationsRequest',
|
||||
'GetTimesResponse',
|
||||
'Station',
|
||||
'StationDataRequest',
|
||||
'SurfaceDataRequest',
|
||||
'UpperAirDataRequest'
|
||||
'GetGridDataRequest',
|
||||
'GetGridInfoRequest',
|
||||
'GetGridNavRequest'
|
||||
]
|
||||
|
||||
from GetGridDataRequest import GetGridDataRequest
|
||||
from GetGridInfoRequest import GetGridInfoRequest
|
||||
from GetGridNavRequest import GetGridNavRequest
|
||||
from GetStationsRequest import GetStationsRequest
|
||||
from GetTimesRequest import GetTimesRequest
|
||||
from GetStationsRequest import GetStationsRequest
|
||||
from GetTimesResponse import GetTimesResponse
|
||||
from Station import Station
|
||||
from StationDataRequest import StationDataRequest
|
||||
from SurfaceDataRequest import SurfaceDataRequest
|
||||
from UpperAirDataRequest import UpperAirDataRequest
|
||||
|
||||
from GetGridDataRequest import GetGridDataRequest
|
||||
from GetGridInfoRequest import GetGridInfoRequest
|
||||
from GetGridNavRequest import GetGridNavRequest
|
||||
|
|
|
@ -5,8 +5,7 @@ __all__ = [
|
|||
'ActivityInfo',
|
||||
'DerivedProduct',
|
||||
'ResponseMessageValidate',
|
||||
'request',
|
||||
'response'
|
||||
'request'
|
||||
]
|
||||
|
||||
from ActivityInfo import ActivityInfo
|
||||
|
|
|
@ -4,12 +4,10 @@
|
|||
__all__ = [
|
||||
'RetrieveAllProductsRequest',
|
||||
'StoreActivityRequest',
|
||||
'StoreDerivedProductRequest',
|
||||
'RetrieveActivityMapRequest'
|
||||
'StoreDerivedProductRequest'
|
||||
]
|
||||
|
||||
from RetrieveAllProductsRequest import RetrieveAllProductsRequest
|
||||
from StoreActivityRequest import StoreActivityRequest
|
||||
from StoreDerivedProductRequest import StoreDerivedProductRequest
|
||||
from RetrieveActivityMapRequest import RetrieveActivityMapRequest
|
||||
|
||||
|
|
|
@ -39,7 +39,7 @@
|
|||
|
||||
import os
|
||||
import logging
|
||||
from awips import AlertVizHandler
|
||||
from ufpy import AlertVizHandler
|
||||
import Record
|
||||
|
||||
avh = AlertVizHandler.AlertVizHandler(host=os.getenv("BROKER_ADDR","localhost"), port=9581, category='LOCAL', source='ANNOUNCER', level=logging.NOTSET)
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
|
||||
|
||||
#
|
||||
# __init__.py for awips package
|
||||
# __init__.py for ufpy package
|
||||
#
|
||||
#
|
||||
# SOFTWARE HISTORY
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
|
||||
|
||||
#
|
||||
# __init__.py for awips.test.dafTests package
|
||||
# __init__.py for ufpy.test.dafTests package
|
||||
#
|
||||
#
|
||||
# SOFTWARE HISTORY
|
||||
|
|
|
@ -18,7 +18,7 @@
|
|||
# further licensing information.
|
||||
##
|
||||
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
import baseDafTestCase
|
||||
|
||||
|
|
|
@ -20,8 +20,8 @@
|
|||
|
||||
from __future__ import print_function
|
||||
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from awips.ThriftClient import ThriftRequestException
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.ThriftClient import ThriftRequestException
|
||||
|
||||
import os
|
||||
import unittest
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
import baseDafTestCase
|
||||
import unittest
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
import baseDafTestCase
|
||||
|
|
|
@ -19,8 +19,8 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from awips.ThriftClient import ThriftRequestException
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.ThriftClient import ThriftRequestException
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
|
||||
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
import baseBufrMosTestCase
|
||||
import unittest
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
import baseBufrMosTestCase
|
||||
import unittest
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
# #
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
import baseDafTestCase
|
||||
|
|
|
@ -22,8 +22,8 @@ from __future__ import print_function
|
|||
import datetime
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.time import TimeRange
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from awips.ThriftClient import ThriftRequestException
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.ThriftClient import ThriftRequestException
|
||||
|
||||
import baseDafTestCase
|
||||
import unittest
|
||||
|
|
|
@ -18,9 +18,9 @@
|
|||
# further licensing information.
|
||||
##
|
||||
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
from awips.dataaccess import CombinedTimeQuery as CTQ
|
||||
from ufpy.dataaccess import CombinedTimeQuery as CTQ
|
||||
|
||||
import unittest
|
||||
import os
|
||||
|
@ -49,7 +49,7 @@ class CombinedTimeQueryTestCase(unittest.TestCase):
|
|||
|
||||
def testSuccessfulQuery(self):
|
||||
req = DAL.newDataRequest('grid')
|
||||
req.setLocationNames('RAP13')
|
||||
req.setLocationNames('RUC130')
|
||||
req.setParameters('T','GH')
|
||||
req.setLevels('300MB', '500MB','700MB')
|
||||
times = CTQ.getAvailableTimes(req);
|
||||
|
@ -60,7 +60,7 @@ class CombinedTimeQueryTestCase(unittest.TestCase):
|
|||
Test that when a parameter is only available on one of the levels that no times are returned.
|
||||
"""
|
||||
req = DAL.newDataRequest('grid')
|
||||
req.setLocationNames('RAP13')
|
||||
req.setLocationNames('RUC130')
|
||||
req.setParameters('T','GH', 'LgSP1hr')
|
||||
req.setLevels('300MB', '500MB','700MB','0.0SFC')
|
||||
times = CTQ.getAvailableTimes(req);
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
|
||||
from __future__ import print_function
|
||||
from shapely.geometry import box
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
import baseDafTestCase
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
|
||||
from __future__ import print_function
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
import baseDafTestCase
|
||||
import unittest
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
|
||||
from __future__ import print_function
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
import baseDafTestCase
|
||||
import unittest
|
||||
|
|
|
@ -21,8 +21,8 @@
|
|||
from __future__ import print_function
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
from shapely.geometry import box, Point
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from awips.ThriftClient import ThriftRequestException
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.ThriftClient import ThriftRequestException
|
||||
|
||||
import baseDafTestCase
|
||||
import unittest
|
||||
|
|
|
@ -20,8 +20,8 @@
|
|||
|
||||
from __future__ import print_function
|
||||
import datetime
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from awips.ThriftClient import ThriftRequestException
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.ThriftClient import ThriftRequestException
|
||||
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.time import TimeRange
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
|
||||
from __future__ import print_function
|
||||
from shapely.geometry import Polygon
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
import baseDafTestCase
|
||||
import unittest
|
||||
|
|
|
@ -20,8 +20,8 @@
|
|||
|
||||
from __future__ import print_function
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from awips.ThriftClient import ThriftRequestException
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.ThriftClient import ThriftRequestException
|
||||
|
||||
import baseDafTestCase
|
||||
import unittest
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
|
||||
import baseDafTestCase
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
|
||||
import baseDafTestCase
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
import baseDafTestCase
|
||||
import unittest
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
import baseDafTestCase
|
||||
import testWarning
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
import baseDafTestCase
|
||||
import unittest
|
||||
|
|
|
@ -21,8 +21,8 @@
|
|||
from __future__ import print_function
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
from shapely.geometry import box
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from awips.ThriftClient import ThriftRequestException
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.ThriftClient import ThriftRequestException
|
||||
|
||||
import baseDafTestCase
|
||||
import unittest
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
|
||||
from __future__ import print_function
|
||||
from shapely.geometry import box
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
import baseDafTestCase
|
||||
|
|
|
@ -20,7 +20,7 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
|
||||
import baseDafTestCase
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
import baseDafTestCase
|
||||
|
|
|
@ -19,8 +19,8 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from awips.ThriftClient import ThriftRequestException
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.ThriftClient import ThriftRequestException
|
||||
|
||||
import baseDafTestCase
|
||||
import shapely.geometry
|
||||
|
|
|
@ -19,7 +19,7 @@
|
|||
##
|
||||
|
||||
from __future__ import print_function
|
||||
from awips.dataaccess import DataAccessLayer as DAL
|
||||
from ufpy.dataaccess import DataAccessLayer as DAL
|
||||
|
||||
from dynamicserialize.dstypes.com.raytheon.uf.common.dataquery.requests import RequestConstraint
|
||||
import baseDafTestCase
|
||||
|
|
|
@ -52,7 +52,7 @@ class ListenThread(threading.Thread):
|
|||
threading.Thread.__init__(self)
|
||||
|
||||
def run(self):
|
||||
from awips import QpidSubscriber
|
||||
from ufpy import QpidSubscriber
|
||||
self.qs = QpidSubscriber.QpidSubscriber(self.hostname, self.portNumber, True)
|
||||
self.qs.topicSubscribe(self.topicName, self.receivedMessage)
|
||||
|
||||
|
|
Loading…
Add table
Reference in a new issue