# Path: ecs_scheduler/triggers.py
# def init():
# def get(trigger_name):
#     def determine_task_count(self, job_data):
#     def __init__(self):
#     def determine_task_count(self, job_data):
#     def _calculate_task_count(self, message_count, job_data):
# class NoOpTrigger:
# class SqsTrigger:


import unittest
from unittest.mock import patch, Mock
from ecs_scheduler.triggers import (
    NoOpTrigger, SqsTrigger, get, init, _triggers
)

        self.assertEqual(3, count)


@patch('boto3.resource')
@patch.dict('ecs_scheduler.triggers._triggers', {})
class InitTests(unittest.TestCase):
    def test(self, fake_resource):
        init()

        self.assertEqual(2, len(_triggers))
        self.assertIsInstance(_triggers['sqs'], SqsTrigger)
        self.assertIsInstance(_triggers['noop'], NoOpTrigger)


class TestTrigger():
    pass


@patch.dict(
    'ecs_scheduler.triggers._triggers',
    {'test': TestTrigger(), 'noop': NoOpTrigger()}
)
class GetTests(unittest.TestCase):
    def test_get_named_trigger(self):
        trigger = get('test')

        self.assertIsInstance(trigger, TestTrigger)

    def test_get_unknown_trigger(self):

# Path: ecs_scheduler/triggers.py
# def init():
# def get(trigger_name):
#     def determine_task_count(self, job_data):
#     def __init__(self):
#     def determine_task_count(self, job_data):
#     def _calculate_task_count(self, message_count, job_data):
# class NoOpTrigger:
# class SqsTrigger:


# Path: test/test_triggers.py
import unittest
from unittest.mock import patch, Mock
from ecs_scheduler.triggers import (
    NoOpTrigger, SqsTrigger, get, init, _triggers
)


        self.assertEqual(3, count)


@patch('boto3.resource')
@patch.dict('ecs_scheduler.triggers._triggers', {})
class InitTests(unittest.TestCase):
    def test(self, fake_resource):
        init()

        self.assertEqual(2, len(_triggers))
        self.assertIsInstance(_triggers['sqs'], SqsTrigger)
        self.assertIsInstance(_triggers['noop'], NoOpTrigger)


class TestTrigger():
    pass


@patch.dict(
    'ecs_scheduler.triggers._triggers',
    {'test': TestTrigger(), 'noop': NoOpTrigger()}
)
class GetTests(unittest.TestCase):
    def test_get_named_trigger(self):
        trigger = get('test')

        self.assertIsInstance(trigger, TestTrigger)

    def test_get_unknown_trigger(self):

        trigger = get('who knows')