diff --git a/data/connection.json b/data/connection.json index e3989b3..e882d3e 100644 --- a/data/connection.json +++ b/data/connection.json @@ -1,6 +1,6 @@ { - "host": "172.21.5.240", + "host": "172.21.5.229", "port": 22, "username": "smart", "password": "00000000" -} \ No newline at end of file +} diff --git a/data/path.json b/data/path.json index 502243d..940e140 100644 --- a/data/path.json +++ b/data/path.json @@ -1,16 +1,9 @@ [ { - "source": "/home/smart/PN/TWC/trace/Weld Point", + "source": "/home/smart/TWC/trace/Technological", "buffer": "/home/andrei/PycharmProjects/traceDelivery/buffer", "destination": "/home/andrei/Desktop/bla", "apply_filter": true, "sigma_filter": 3 - }, - { - "source": "/home/smart/PN/TWC/trace/test1", - "buffer": "/home/andrei/PycharmProjects/traceDelivery/buffer", - "destination": "/home/andrei/Desktop/bla", - "apply_filter": false, - "sigma_filter": 3 } -] \ No newline at end of file +] diff --git a/src/main.py b/src/main.py index cba0cd3..987b962 100644 --- a/src/main.py +++ b/src/main.py @@ -1,6 +1,7 @@ import json import os from concurrent.futures import ThreadPoolExecutor +import threading from remote.client import SSHClient from remote.connection_data import SSHConnectionParams @@ -34,7 +35,9 @@ def start_subscription(ssh_connection_object: SSHConnectionParams, client.connect() subscriber = Subscriber(client.sftp, element) tuner.accept(subscriber) - executor.submit(subscriber.subscribe) + t = threading.Thread(target=subscriber.subscribe(), args=()) + t.start() + # executor.submit(subscriber.subscribe) def main():