import json

import boto.swf.layer2 as swf

import flow

# get initial_context by see_jobs() along with start date

initial_context = dict(
	"start_time"='2016-09-01',
	"content_owner"='Orchard',
	"job_id"="a1ee8657-6f68-43bf-819e-20be1ea17010"
)

hello_world_flow = flow.HelloWorldFlow('dev', '1.0')
workflow_execution = swf.WorkflowType(
        name=hello_world_flow.name,
        domain=hello_world_flow.domain,
        version=hello_world_flow.version,
        task_list=hello_world_flow.name).start(
            input=json.dumps(initial_context))

print("Launching SWF for flow '{}' with WorkflowId '{}' and RunId '{}'".format(
    workflow_execution.name,
    workflow_execution.workflowId,
    workflow_execution.runId))