This is an automated email from the ASF dual-hosted git repository.
nicknezis pushed a change to branch nicknezis/tracker-fixes
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git.
from 1723c15 Updated pylint to fix Python 3.9 issues
add df97725 Whole lot of formatting changes
No new revisions were added by this update.
Summary of changes:
bazel_configure.py | 14 ++--
examples/src/python/bolt/consume_bolt.py | 2 +-
examples/src/python/bolt/count_bolt.py | 6 +-
examples/src/python/bolt/half_ack_bolt.py | 6 +-
examples/src/python/bolt/stateful_count_bolt.py | 6 +-
examples/src/python/bolt/stream_aggregate_bolt.py | 2 +-
examples/src/python/bolt/window_size_bolt.py | 2 +-
examples/src/python/spout/multi_stream_spout.py | 6 +-
examples/src/python/spout/stateful_word_spout.py | 6 +-
examples/src/python/spout/word_spout.py | 8 +-
heron/common/src/python/pex_loader.py | 22 ++---
heron/executor/src/python/heron_executor.py | 83 +++++++++----------
.../tests/python/heron_executor_unittest.py | 32 ++++----
heron/instance/src/python/basics/base_instance.py | 10 +--
heron/instance/src/python/basics/bolt_instance.py | 4 +-
heron/instance/src/python/basics/spout_instance.py | 11 ++-
heron/instance/src/python/instance.py | 17 ++--
heron/instance/src/python/network/heron_client.py | 40 +++++----
.../src/python/network/metricsmgr_client.py | 13 ++-
heron/instance/src/python/network/protocol.py | 5 +-
.../instance/src/python/network/socket_options.py | 4 +-
.../src/python/utils/metrics/metrics_helper.py | 8 +-
.../instance/src/python/utils/misc/communicator.py | 4 +-
.../python/utils/misc/custom_grouping_helper.py | 12 +--
.../instance/src/python/utils/misc/pplan_helper.py | 10 +--
.../python/utils/topology/topology_context_impl.py | 2 +-
heron/shell/src/python/handlers/downloadhandler.py | 2 +-
heron/shell/src/python/handlers/pidhandler.py | 2 +-
heron/statemgrs/src/python/configloader.py | 9 ++-
heron/statemgrs/src/python/statemanager.py | 7 +-
heron/statemgrs/src/python/statemanagerfactory.py | 2 +-
heron/statemgrs/src/python/zkstatemanager.py | 32 ++++----
heron/tools/cli/src/python/args.py | 9 ++-
heron/tools/cli/src/python/cdefs.py | 2 +-
heron/tools/cli/src/python/cli_helper.py | 14 ++--
heron/tools/cli/src/python/cliconfig.py | 8 +-
heron/tools/cli/src/python/config.py | 12 +--
heron/tools/cli/src/python/execute.py | 7 +-
heron/tools/cli/src/python/main.py | 31 ++++---
heron/tools/cli/src/python/opts.py | 6 +-
heron/tools/cli/src/python/result.py | 18 ++---
heron/tools/cli/src/python/submit.py | 41 +++++-----
heron/tools/cli/src/python/update.py | 13 +--
heron/tools/cli/src/python/version.py | 6 +-
heron/tools/cli/tests/python/opts_unittest.py | 8 +-
heron/tools/common/src/python/clients/tracker.py | 50 ++++++------
heron/tools/common/src/python/utils/config.py | 57 +++++++------
heron/tools/explorer/src/python/logicalplan.py | 8 +-
heron/tools/explorer/src/python/main.py | 6 +-
heron/tools/explorer/src/python/physicalplan.py | 6 +-
heron/tools/explorer/src/python/topologies.py | 6 +-
heron/tools/tracker/src/python/main.py | 6 +-
heron/tools/tracker/src/python/utils.py | 7 +-
heron/tools/ui/src/python/main.py | 10 +--
heronpy/api/bolt/base_bolt.py | 2 +-
heronpy/api/component/component_spec.py | 26 +++---
heronpy/api/spout/base_spout.py | 2 +-
heronpy/api/stream.py | 10 +--
heronpy/api/topology.py | 21 +++--
heronpy/connectors/pulsar/pulsarspout.py | 24 +++---
heronpy/connectors/textfiles/textfilesgenerator.py | 6 +-
heronpy/streamlet/config.py | 2 +-
heronpy/streamlet/impl/consumebolt.py | 2 +-
heronpy/streamlet/impl/filterbolt.py | 2 +-
heronpy/streamlet/impl/flatmapbolt.py | 2 +-
heronpy/streamlet/impl/generatorspout.py | 2 +-
heronpy/streamlet/impl/joinbolt.py | 10 +--
heronpy/streamlet/impl/logbolt.py | 2 +-
heronpy/streamlet/impl/mapbolt.py | 2 +-
heronpy/streamlet/impl/repartitionbolt.py | 2 +-
heronpy/streamlet/impl/supplierspout.py | 2 +-
heronpy/streamlet/impl/transformbolt.py | 2 +-
heronpy/streamlet/impl/unionbolt.py | 2 +-
integration_test/src/python/http_server/main.py | 12 +--
.../common/bolt/count_aggregator_bolt.py | 2 +-
.../common/bolt/word_count_bolt.py | 4 +-
.../integration_test/core/aggregator_bolt.py | 10 +--
.../integration_test/core/integration_test_bolt.py | 6 +-
.../core/integration_test_spout.py | 14 ++--
.../integration_test/core/test_topology_builder.py | 2 +-
.../src/python/local_test_runner/main.py | 2 +-
.../src/python/local_test_runner/test_scale_up.py | 5 +-
.../src/python/local_test_runner/test_template.py | 37 +++++----
integration_test/src/python/test_runner/main.py | 77 ++++++++----------
.../src/python/topology_test_runner/main.py | 94 +++++++++-------------
scripts/shutils/save-logs.py | 10 +--
third_party/python/semver/semver.py | 8 +-
tools/rules/pex/wrapper/pex_wrapper.py | 6 +-
88 files changed, 541 insertions(+), 591 deletions(-)
