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())