Change to monasca-common simport
Use monasca-common simport library Closes-Bug: #1596331 Change-Id: I695d6db9c5c49c0120e73b76ea75f7a30222419d
This commit is contained in:
parent
b3f85e134e
commit
90b20bfd41
|
@ -13,8 +13,8 @@
|
|||
# under the License.
|
||||
|
||||
import abc
|
||||
from monasca_common.simport import simport
|
||||
from oslo_config import cfg
|
||||
import simport
|
||||
import six
|
||||
|
||||
|
||||
|
|
|
@ -27,8 +27,8 @@ from pyspark.sql import SQLContext
|
|||
|
||||
import json
|
||||
import logging
|
||||
from monasca_common.simport import simport
|
||||
from oslo_config import cfg
|
||||
import simport
|
||||
import time
|
||||
|
||||
from monasca_transform.config.config_initializer import ConfigInitializer
|
||||
|
|
|
@ -16,8 +16,8 @@ import abc
|
|||
import json
|
||||
from kafka import KafkaClient
|
||||
from kafka import SimpleProducer
|
||||
from monasca_common.simport import simport
|
||||
from oslo_config import cfg
|
||||
import simport
|
||||
|
||||
|
||||
class MessageAdapter(object):
|
||||
|
|
|
@ -20,8 +20,8 @@ from pyspark.streaming.kafka import OffsetRange
|
|||
|
||||
import datetime
|
||||
import logging
|
||||
from monasca_common.simport import simport
|
||||
from oslo_config import cfg
|
||||
import simport
|
||||
|
||||
|
||||
from monasca_transform.component.insert.kafka_insert import KafkaInsert
|
||||
|
|
|
@ -2,10 +2,10 @@ PyMySQL
|
|||
six>=1.7.0 # MIT
|
||||
SQLAlchemy<1.1.0,>=0.9.9
|
||||
kafka-python<=0.9.5
|
||||
simport>=0.0.dev0
|
||||
stevedore>=1.5.0 # Apache-2.0
|
||||
monasca-common>=0.0.2
|
||||
oslo.config>=1.2.1
|
||||
oslo.log
|
||||
oslo.service
|
||||
tooz
|
||||
kazoo
|
||||
|
||||
|
|
|
@ -11,8 +11,8 @@
|
|||
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
# License for the specific language governing permissions and limitations
|
||||
# under the License.
|
||||
from monasca_common.simport import simport
|
||||
from monasca_transform.messaging.adapter import MessageAdapter
|
||||
import simport
|
||||
|
||||
|
||||
class DummyAdapter(MessageAdapter):
|
||||
|
|
Loading…
Reference in New Issue