Add the OptionsFlow to batch processing

metrik/__init__.py

@@ -1,2 +1,2 @@
-__version__ = '0.5.0'
+__version__ = '0.5.1'
 __release__ = __version__

metrik/batch.py

@@ -9,10 +9,12 @@ from os import path
 
 from metrik.conf import get_config
 from metrik.flows.equities_flow import EquitiesFlow
+from metrik.flows.options_flow import OptionsFlow
 from metrik import __version__
 
 flows = {
-    'EquitiesFlow': EquitiesFlow
+    'EquitiesFlow': OptionsFlow,
+    'OptionsFlow': OptionsFlow
 }
 
 

metrik/default.conf

@@ -5,10 +5,10 @@ mongo_port=27017
 mongo_database=metrik
 
 [tradeking]
-consumer_key=
-consumer_secret=
-oauth_token=
-oauth_token_secret=
+consumer_key=FvCJ6uMDGosZurOT6I19UTPHCVRtHkCoNBSLsX22
+consumer_secret=WIZKUg3jQnfJcznsXtvvbBgNzIODhnRCU5iOFNqj
+oauth_token=S3rirDdjQ2Z3ou6Rdx1EQPDTd7Y4Bdz6Cj7svT46
+oauth_token_secret=OxdALZqugIAGrOvmL9HynHxhGda9UZUFSNYu0uNi
 
 [statestreet]
 etf_holdings:

metrik/flows/options_flow.py

@@ -3,9 +3,9 @@ from metrik.conf import get_config
 from metrik.tasks.cboe import CboeOptionableList
 from metrik.tasks.tradeking import TradekingOptionsQuotes
 
-class EquitiesFlow(Flow):
+class OptionsFlow(Flow):
     def __init__(self, *args, **kwargs):
-        super(EquitiesFlow, self).__init__(*args, **kwargs)
+        super(OptionsFlow, self).__init__(*args, **kwargs)
 
     @staticmethod
     def get_schedule():