<commit_before>import rpyc
from rpyc.utils.server import ThreadedServer
import copy
import inspect
import shutil
import os

class Registry:
    connect_list = []
    disconnect_list = []
    setup_list = []
    launch_list = []
    run_list = []
    teardown_list = []

    server = None

    @staticmethod
    def connect(fun):
        Registry.connect_list.append(fun)
        return fun

    @staticmethod
    def disconnect(fun):
        Registry.disconnect_list.append(fun)
        return fun

    @staticmethod
    def setup(fun):
        Registry.setup_list.append(fun)
        return fun

    @staticmethod
    def launch(fun):
        Registry.launch_list.append(fun)
        return fun

    @staticmethod
    def run(fun):
        Registry.run_list.append(fun)
        return fun

    @staticmethod
    def teardown(fun):
        Registry.teardown_list.append(fun)
        return fun

    @staticmethod
    def experiment(cls, port = 18861):
        def archive(self, *filenames):
            output = []
            for fn in filenames:
                output.append(os.getcwd())
                # shutil.make_archive(fn, 'gztar', root_dir='gcc')
            return output

        cls.exposed_archive = archive
        server = ThreadedServer(cls, port = 18861, protocol_config = {'allow_pickle':True})
        print("Starting RPyC Server...")
        server.start()

class Service(rpyc.Service):
    def on_connect(self, *args, **kwargs):<commit_msg>maybe fixed archive testing?<commit_after>import rpyc
from rpyc.utils.server import ThreadedServer
import copy
import inspect
import shutil
import os

class Registry:
    connect_list = []
    disconnect_list = []
    setup_list = []
    launch_list = []
    run_list = []
    teardown_list = []

    server = None

    @staticmethod
    def connect(fun):
        Registry.connect_list.append(fun)
        return fun

    @staticmethod
    def disconnect(fun):
        Registry.disconnect_list.append(fun)
        return fun

    @staticmethod
    def setup(fun):
        Registry.setup_list.append(fun)
        return fun

    @staticmethod
    def launch(fun):
        Registry.launch_list.append(fun)
        return fun

    @staticmethod
    def run(fun):
        Registry.run_list.append(fun)
        return fun

    @staticmethod
    def teardown(fun):
        Registry.teardown_list.append(fun)
        return fun

    @staticmethod
    def experiment(cls, port = 18861):
        def archive(self, *filenames):
            output = []
            for fn in filenames:
                output.append(os.getcwd())
                # shutil.make_archive(fn, 'gztar', root_dir='gcc')
            return output

        cls.exposed_archive = archive
        server = ThreadedServer(cls, port = 18861, protocol_config = {'allow_pickle':True})
        print("Starting RPyC Server...")
        server.start()
        return cls

class Service(rpyc.Service):
    def on_connect(self, *args, **kwargs):
{'fraction_non_alphanumeric': 0.0956081081081081, 'fraction_numerical': 0.006756756756756757, 'mean_word_length': 2.29, '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': '4372368', 'n_tokens_mistral': 925, 'n_tokens_neox': 863, 'n_words': 198}