From c3484ac0cca2e10cfc080b1859d4ce80ac5f6f51 Mon Sep 17 00:00:00 2001
From: bspeice <bspeice.nc@gmail.com>
Date: Thu, 24 Nov 2016 18:57:49 -0500
Subject: [PATCH] Add the OptionsFlow to batch processing

---
 metrik/__init__.py           | 2 +-
 metrik/batch.py              | 4 +++-
 metrik/default.conf          | 8 ++++----
 metrik/flows/options_flow.py | 4 ++--
 4 files changed, 10 insertions(+), 8 deletions(-)

diff --git a/metrik/__init__.py b/metrik/__init__.py
index fa7fdae..ccb6015 100644
--- a/metrik/__init__.py
+++ b/metrik/__init__.py
@@ -1,2 +1,2 @@
-__version__ = '0.5.0'
+__version__ = '0.5.1'
 __release__ = __version__
\ No newline at end of file
diff --git a/metrik/batch.py b/metrik/batch.py
index 048bda2..a1ad11b 100644
--- a/metrik/batch.py
+++ b/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
 }
 
 
diff --git a/metrik/default.conf b/metrik/default.conf
index 32fa605..40ea266 100644
--- a/metrik/default.conf
+++ b/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:
diff --git a/metrik/flows/options_flow.py b/metrik/flows/options_flow.py
index 1644cf7..4121c71 100644
--- a/metrik/flows/options_flow.py
+++ b/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():