You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by al...@apache.org on 2020/08/17 13:30:44 UTC

[skywalking-python] 03/04: fix style

This is an automated email from the ASF dual-hosted git repository.

alonelaval pushed a commit to branch process-propagation
in repository https://gitbox.apache.org/repos/asf/skywalking-python.git

commit 01e2014982e031a2d46d311221e30a8d46b493ab
Author: huawei <hu...@bit-s.cn>
AuthorDate: Mon Aug 17 21:28:51 2020 +0800

    fix style
---
 skywalking/agent/__init__.py                 | 20 --------------------
 skywalking/trace/ipc/process.py              |  5 -----
 tests/plugin/sw_process/services/consumer.py |  4 ++--
 3 files changed, 2 insertions(+), 27 deletions(-)

diff --git a/skywalking/agent/__init__.py b/skywalking/agent/__init__.py
index 8200f4c..b2b82a7 100644
--- a/skywalking/agent/__init__.py
+++ b/skywalking/agent/__init__.py
@@ -80,26 +80,6 @@ def start():
     __report_thread.start()
 
 
-# def restart():
-#     global __heartbeat_thread
-#     __heartbeat_thread = Thread(name='HeartbeatThread', target=__heartbeat, daemon=True)
-#     global __report_thread
-#     __report_thread = Thread(name='ReportThread', target=__report, daemon=True)
-#     global __queue
-#     __queue = Queue(maxsize=10000)
-#     global __finished
-#     __finished = Event()
-#     global __protocol
-#     __protocol = Protocol()  # type: Protocol
-#     global __started
-#     from skywalking import loggings
-#     loggings.init()
-#     __started = True
-#     __init()
-#     __heartbeat_thread.start()
-#     __report_thread.start()
-
-
 def stop():
     __finished.set()
 
diff --git a/skywalking/trace/ipc/process.py b/skywalking/trace/ipc/process.py
index b682ba5..6799e0e 100644
--- a/skywalking/trace/ipc/process.py
+++ b/skywalking/trace/ipc/process.py
@@ -28,12 +28,7 @@ class SwProcess(Process):
         self._sw_config = config.serialize()
 
     def run(self):
-        print(config.trace_ignore)
-        print(config.service_name)
-        print(config.collector_address)
         if agent.started() is False:
-            print("startttt-----------------")
             config.deserialize(self._sw_config)
             agent.start()
-        print(self._sw_config)
         super(SwProcess, self).run()
diff --git a/tests/plugin/sw_process/services/consumer.py b/tests/plugin/sw_process/services/consumer.py
index 725aaf9..cf30740 100644
--- a/tests/plugin/sw_process/services/consumer.py
+++ b/tests/plugin/sw_process/services/consumer.py
@@ -22,7 +22,7 @@ import multiprocessing
 
 
 def post():
-    requests.post("http://provider:9091/users")
+    requests.post("http://127.0.0.1:9091/users")
 
 
 if __name__ == '__main__':
@@ -46,7 +46,7 @@ if __name__ == '__main__':
         p1.start()
         p1.join()
 
-        res = requests.post("http://provider:9091/users")
+        res = requests.post("http://127.0.0.1:9091/users")
 
         return jsonify(res.json())