<commit_before>from libsubmit.providers import LocalProvider
from libsubmit.channels import LocalChannel

from parsl.config import Config
from parsl.executors.mpix import MPIExecutor

config = Config(
    executors=[
        MPIExecutor(
            label="MPIX_Local",

            # Set the public ip of the machine you are launching the workflow from. Default: 127.0.0.1 for local runs.
            # public_ip = "10.236.1.193"

            # Set the worker ports explicitly. This is useful for re-using workers between workflows.
            # worker_ports=(50078, 50079),

            # Set a port range from which ports should be picked.
            worker_port_range=(40010, 40020),

            # The fabric_threaded.py script launches the MPI version
            # launch_cmd="./cleanup.sh ; mpiexec -np {tasks_per_node} fabric_threaded.py {debug}",
            launch_cmd="./cleanup.sh ; \
python fabric_single_node.py {debug} --task_url={task_url} --result_url={result_url}",
            # launch_cmd="./cleanup.sh ",
            # launch_cmd="sleep 600",

            # Enable engine debug logging
            engine_debug=True,
            provider=LocalProvider(
                channel=LocalChannel(),
                init_blocks=1,
                max_blocks=1,
                tasks_per_node=3,
            )
        )
    ],
    strategy=None,
)
<commit_msg>Updating mpix_local config<commit_after>from libsubmit.providers import LocalProvider
from libsubmit.channels import LocalChannel

from parsl.config import Config
from parsl.executors.mpix import MPIExecutor

config = Config(
    executors=[
        MPIExecutor(
            label="MPIX_Local",

            # Set the public ip of the machine you are launching the workflow from. Default: 127.0.0.1 for local runs.
            # public_ip = "10.236.1.193"

            # Set the worker ports explicitly. This is useful for re-using workers between workflows.
            # worker_ports=(50078, 50079),

            # Set a port range from which ports should be picked.
            worker_port_range=(40010, 40020),

            # The fabric_threaded.py script launches the MPI version
            launch_cmd="./cleanup.sh ; mpiexec -np 4 python3 ./fabric_threaded.py {debug} --task_url={task_url} --result_url={result_url}",
            # launch_cmd="./cleanup.sh ; python3 ./fabric_single_node.py {debug} --task_url={task_url} --result_url={result_url} ",
            # launch_cmd="./cleanup.sh ",
            # launch_cmd="sleep 600",

            # Enable engine debug logging
            engine_debug=True,
            provider=LocalProvider(
                channel=LocalChannel(),
                init_blocks=1,
                max_blocks=1,
                tasks_per_node=1,
            )
        )
    ],
    strategy=None,
)

{'fraction_non_alphanumeric': 0.09074733096085409, 'fraction_numerical': 0.030249110320284697, 'mean_word_length': 2.0992282249173098, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 4, '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': '3727105', 'n_tokens_mistral': 842, 'n_tokens_neox': 760, 'n_words': 207}