<commit_before>from setuptools import setup, find_packages

entry_points = '''
[flow.protocol.message_classes]
execute_node = flow.orchestrator.messages:ExecuteNodeMessage
status_request = flow.orchestrator.messages:NodeStatusRequestMessage
status_response = flow.orchestrator.messages:NodeStatusResponseMessage
submit_command = flow.command_runner.messages:CommandLineSubmitMessage
command_result = flow.command_runner.messages:CommandLineResponseMessage

[flow.commands]
status = flow.commands.status:StatusCommand
benchmark = flow.commands.benchmark:BenchmarkCommand
orchestrator = flow.commands.service:ServiceCommand
local_command_line_service = flow.commands.service:ServiceCommand
lsf_command_line_service = flow.commands.service:ServiceCommand
configure_rabbit_mq = flow.commands.configurerabbitmq:ConfigureRabbitMQCommand

[flow.factories]
status_command = flow.commands.status:StatusCommand


dictionary_factory = flow.factories:dictionary_factory

redis_storage_singleton = flow.storage:redis_storage_singleton

asynchronous_amqp_broker = flow.brokers.strategic_broker:StrategicAmqpBroker
blocking_broker = flow.brokers.blocking:BlockingAmqpBroker
publisher_confirm_acking = flow.brokers.acking_strategies:PublisherConfirmation
immediate_acking = flow.broker.acking_strategies:Immediate

orchestrator_service_interface = flow.orchestrator.client:OrchestratorClient
shell_command_service_interface = flow.command_runner.client:CommandLineClient

execute_node_handler = flow.orchestrator.handlers:ExecuteNodeHandler
node_status_request_handler = flow.orchestrator.handlers:NodeStatusRequestHandler
method_descriptor_handler = flow.orchestrator.handlers:MethodDescriptorHandler

command_line_submit_handler = flow.command_runner.handler:CommandLineSubmitMessageHandler
command_line_local_executor = flow.command_runner.executors.local:SubprocessExecutor
command_line_lsf_executor = flow.command_runner.executors.lsf:LSFExecutor
'''

setup(
        name = 'flow',
        version = '0.1',
        packages = find_packages(exclude=[
            'unit_tests',
            'integration_tests',
            'system_tests'
        ]),
        entry_points = entry_points,
        install_requires = [
            'argparse',
            'pika',
            'platform-python-lsf-api',
            'pygraphviz',
            'pyyaml',
            'redis',
        ],
        setup_requires = [
            'nose',
        ],
        tests_require = [
            'mock',
            'nose',
            'coverage',
            'fakeredis',
        ],
        test_suite = 'unit_tests',
)
<commit_msg>rename command configure_rabbit_mq to configure_rabbitmq<commit_after>from setuptools import setup, find_packages

entry_points = '''
[flow.protocol.message_classes]
execute_node = flow.orchestrator.messages:ExecuteNodeMessage
status_request = flow.orchestrator.messages:NodeStatusRequestMessage
status_response = flow.orchestrator.messages:NodeStatusResponseMessage
submit_command = flow.command_runner.messages:CommandLineSubmitMessage
command_result = flow.command_runner.messages:CommandLineResponseMessage

[flow.commands]
status = flow.commands.status:StatusCommand
benchmark = flow.commands.benchmark:BenchmarkCommand
orchestrator = flow.commands.service:ServiceCommand
local_command_line_service = flow.commands.service:ServiceCommand
lsf_command_line_service = flow.commands.service:ServiceCommand
configure_rabbitmq = flow.commands.configurerabbitmq:ConfigureRabbitMQCommand

[flow.factories]
status_command = flow.commands.status:StatusCommand


dictionary_factory = flow.factories:dictionary_factory

redis_storage_singleton = flow.storage:redis_storage_singleton

asynchronous_amqp_broker = flow.brokers.strategic_broker:StrategicAmqpBroker
blocking_broker = flow.brokers.blocking:BlockingAmqpBroker
publisher_confirm_acking = flow.brokers.acking_strategies:PublisherConfirmation
immediate_acking = flow.broker.acking_strategies:Immediate

orchestrator_service_interface = flow.orchestrator.client:OrchestratorClient
shell_command_service_interface = flow.command_runner.client:CommandLineClient

execute_node_handler = flow.orchestrator.handlers:ExecuteNodeHandler
node_status_request_handler = flow.orchestrator.handlers:NodeStatusRequestHandler
method_descriptor_handler = flow.orchestrator.handlers:MethodDescriptorHandler

command_line_submit_handler = flow.command_runner.handler:CommandLineSubmitMessageHandler
command_line_local_executor = flow.command_runner.executors.local:SubprocessExecutor
command_line_lsf_executor = flow.command_runner.executors.lsf:LSFExecutor
'''

setup(
        name = 'flow',
        version = '0.1',
        packages = find_packages(exclude=[
            'unit_tests',
            'integration_tests',
            'system_tests'
        ]),
        entry_points = entry_points,
        install_requires = [
            'argparse',
            'pika',
            'platform-python-lsf-api',
            'pygraphviz',
            'pyyaml',
            'redis',
        ],
        setup_requires = [
            'nose',
        ],
        tests_require = [
            'mock',
            'nose',
            'coverage',
            'fakeredis',
        ],
        test_suite = 'unit_tests',
)

{'fraction_non_alphanumeric': 0.07824427480916031, 'fraction_numerical': 0.0007633587786259542, 'mean_word_length': 4.55779427359491, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '1126128', 'n_tokens_mistral': 1505, 'n_tokens_neox': 1483, 'n_words': 182}