2020-03-04 23:56:47 +00:00

25 lines
528 B
Python

#!/usr/bin/env python
import sys
sys.path.append('/home/price-collector/')
from threading import Thread
from pricing.collector import collector
from probes.probes import runFlaskProbes
def callCollector(args):
collector(args)
def callProbes():
runFlaskProbes()
if __name__=='__main__':
Thread(target=callProbes).start()
# Dynamically create new child for each currency
currencies = [ "btc_usd" ]
for i in range(len(currencies)):
Thread(target=callCollector, args=[currencies[i]]).start()