x/stacktach-sandbox
Code Issues Proposed changes

cleaned up some terminology

Browse Source
This commit is contained in:
Sandy Walsh 2014-09-05 20:56:15 +00:00
parent bb2886eb1d
commit a504a24b12
3 changed files with 19 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
oahu_config.py
View File

@ -49,8 +49,8 @@ class RequestIdCallback(pipeline_callback.PipelineCallback):
def commit(self, stream, scratchpad): def commit(self, stream, scratchpad):
print "Req: %s %s time delta = %s" % (scratchpad['request_id'], print "Req: %s %s time delta = %s" % (scratchpad['request_id'],
scratchpad['operation'], scratchpad['operation'],
scratchpad['delta']) scratchpad['delta'])
class EodExistsCallback(pipeline_callback.PipelineCallback): class EodExistsCallback(pipeline_callback.PipelineCallback):
@ -74,9 +74,9 @@ class Config(oahu.config.Config):
# Trigger names have to be consistent across all workers # Trigger names have to be consistent across all workers
# (yagi and daemons). # (yagi and daemons).
by_request = trigger_definition.TriggerDefinition("request-id", by_request = trigger_definition.TriggerDefinition("request-id",
["_context_request_id", ], ["_context_request_id", ], # Match criteria
criteria.Inactive(60), criteria.Inactive(60), # Trigger criteria
[self.request_id_callback,], [self.request_id_callback,], # Pipeline processing
debug=True) debug=True)
# This trigger requires a Trait called "when_date" which is # This trigger requires a Trait called "when_date" which is
@ -98,11 +98,11 @@ class Config(oahu.config.Config):
def get_distiller_config(self): def get_distiller_config(self):
return "" return ""
def get_ready_chunk_size(self): def get_ready_chunk_size(self): # Check for Ready streams.
return 100 return 100
def get_expiry_chunk_size(self): def get_trigger_chunk_size(self): # Find streams ready to Trigger.
return 1000 return 1000
def get_completed_chunk_size(self): def get_completed_chunk_size(self): # Cleanup completed streams.
return -1 return -1

19
screenrc
View File

@ -1,21 +1,22 @@
sessionname tach sessionname tach
hardstatus alwayslastline '%{= .} %-Lw%{= .}%> %n%f %t*%{= .}%+Lw%< %-=%{g}(%{d}%H/%l%{g})' hardstatus alwayslastline '%{= .} %-Lw%{= .}%> %n%f %t*%{= .}%+Lw%< %-=%{g}(%{d}%H/%l%{g})'
screen -t gen bash screen -t quincy bash
stuff "cd git/notigen/bin; python event_pump.py ../templates 2 0\r" stuff "cd git/quincy/quincy; gunicorn --log-file=- 'api:get_api(config_location=\"../../../quincy.conf\")'\r"
#stuff "cd git/quincy/quincy; gunicorn --log-file=- 'api:get_api()'\r"
screen -t bash bash
stuff "klugman streams\r"
screen -t yagi1 bash screen -t yagi1 bash
stuff "cd git/yagi/bin; ./yagi-event --config ../../../shoebox.conf\r" stuff "cd git/yagi/bin; ./yagi-event --config ../../../shoebox.conf\r"
screen -t yagi2 bash screen -t yagi2 bash
stuff "cd git/yagi/bin; ./yagi-event --config ../../../shoebox.conf\r" stuff "cd git/yagi/bin; ./yagi-event --config ../../../shoebox.conf\r"
screen -t quincy bash screen -t trigger bash
stuff "cd git/quincy/quincy; gunicorn --log-file=- 'api:get_api(config_location=\"../../../quincy.conf\")'\r" stuff "pipeline trigger \".|oahu_config:Config\" --polling_rate=20\r"
stuff "cd git/quincy/quincy; gunicorn --log-file=- 'api:get_api()'\r"
screen -t expired bash
stuff "pipeline expired \".|oahu_config:Config\" --polling_rate=20\r"
screen -t ready1 bash screen -t ready1 bash
stuff "pipeline ready \".|oahu_config:Config\" --polling_rate=20\r" stuff "pipeline ready \".|oahu_config:Config\" --polling_rate=20\r"
screen -t ready2 bash screen -t ready2 bash
stuff "pipeline ready \".|oahu_config:Config\" --polling_rate=20\r" stuff "pipeline ready \".|oahu_config:Config\" --polling_rate=20\r"
screen -t completed bash screen -t completed bash
stuff "pipeline completed \".|oahu_config:Config\" --polling_rate=20\r" stuff "pipeline completed \".|oahu_config:Config\" --polling_rate=20\r"
screen -t bash bash screen -t gen bash
stuff "klugman streams\r" stuff "cd git/notigen/bin; python event_pump.py ../templates 2 0\r"

2
shoebox.conf
View File

@ -1,5 +1,5 @@
[global] [global]
verbose = True verbose = False
debug = True debug = True
update_timer = 10 update_timer = 10