ardere/handler.py at master · loads/ardere · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
# First some funky path manipulation so that we can work properly in
# the AWS environment
import sys
import os
dir_path = os.path.dirname(os.path.realpath(__file__))
sys.path.append(dir_path)

from ardere.step_functions import AsynchronousPlanRunner


def populate_missing_instances(event, context):
    runner = AsynchronousPlanRunner(event, context)
    return runner.populate_missing_instances()


def ensure_metrics_available(event, context):
    runner = AsynchronousPlanRunner(event, context)
    return runner.ensure_metrics_available()


def ensure_metric_sources_created(event, context):
    runner = AsynchronousPlanRunner(event, context)
    return runner.ensure_metric_sources_created()


def create_ecs_services(event, context):
    runner = AsynchronousPlanRunner(event, context)
    return runner.create_ecs_services()


def wait_for_cluster_ready(event, context):
    runner = AsynchronousPlanRunner(event, context)
    return runner.wait_for_cluster_ready()


def signal_cluster_start(event, context):
    runner = AsynchronousPlanRunner(event, context)
    return runner.signal_cluster_start()


def check_for_cluster_done(event, context):
    runner = AsynchronousPlanRunner(event, context)
    return runner.check_for_cluster_done()


def cleanup_cluster(event, context):
    runner = AsynchronousPlanRunner(event, context)
    return runner.cleanup_cluster()


def check_drain(event, context):
    return AsynchronousPlanRunner(event, context).check_drained()