Not That Simple Workflow - A layer around AWS SWF
Common denominator of our infopark internal services using AWS Simple Workflow.
gem 'ntswf', '~> 2.0'
config = {domain: 'my_domain', unit: 'my_app'} # ...
Ntswf.create(:client, config).start_execution(
execution_id: 'my_singleton_task',
name: 'my_worker_name',
params: {my_param: :param},
unit: 'my_worker',
)
See {Ntswf::Base#configure} for configuration options.
config = {domain: 'my_domain', unit: 'my_app'} # ...
Ntswf.create(:decision_worker, config).process_decisions
config = {domain: 'my_domain', unit: 'my_worker'} # ...
worker = Ntswf.create(:activity_worker, config)
worker.on_activity ->(task) { {outcome: task.params['my_param']} }
worker.process_activities
See {Ntswf::Utils}