25 lines
530 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()