Fix PEP8 tests for Python 3
* relace long with int * replace execfile with exec Change-Id: If98949fa5f49091fbf11c95a65302a4f844538c9 Story: 2003240 Task: 26827
This commit is contained in:
parent
fba8cef150
commit
8257dd9f42
|
@ -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