Merge "Fix PEP8 tests for Python 3"
This commit is contained in:
commit
474d358c1d
@ -13,7 +13,7 @@
|
|||||||
# under the License.
|
# under the License.
|
||||||
|
|
||||||
activate_this_file = "/opt/monasca/transform/venv/bin/activate_this.py"
|
activate_this_file = "/opt/monasca/transform/venv/bin/activate_this.py"
|
||||||
execfile(activate_this_file, dict(__file__=activate_this_file))
|
exec(open(activate_this_file).read(), dict(__file__=activate_this_file))
|
||||||
|
|
||||||
from monasca_transform.driver.mon_metrics_kafka import invoke
|
from monasca_transform.driver.mon_metrics_kafka import invoke
|
||||||
|
|
||||||
|
@ -15,7 +15,7 @@
|
|||||||
import sys
|
import sys
|
||||||
|
|
||||||
activate_this_file = "/opt/monasca/transform/venv/bin/activate_this.py"
|
activate_this_file = "/opt/monasca/transform/venv/bin/activate_this.py"
|
||||||
execfile(activate_this_file, dict(__file__=activate_this_file))
|
exec(open(activate_this_file).read(), dict(__file__=activate_this_file))
|
||||||
|
|
||||||
from monasca_transform.service.transform_service import main_service
|
from monasca_transform.service.transform_service import main_service
|
||||||
|
|
||||||
|
@ -118,7 +118,7 @@ class MonMetricsKafkaProcessor(object):
|
|||||||
# partition = saved_offset_spec[composite_key]
|
# partition = saved_offset_spec[composite_key]
|
||||||
from_offsets[
|
from_offsets[
|
||||||
TopicAndPartition(spec_topic, spec_partition)
|
TopicAndPartition(spec_topic, spec_partition)
|
||||||
] = long(spec_until_offset)
|
] = int(spec_until_offset)
|
||||||
|
|
||||||
MonMetricsKafkaProcessor.log_debug(
|
MonMetricsKafkaProcessor.log_debug(
|
||||||
"get_kafka_stream: calling createDirectStream :"
|
"get_kafka_stream: calling createDirectStream :"
|
||||||
|
Loading…
Reference in New Issue
Block a user