assert manager._callback_to_execute[dag1_req1.full_filepath] == [dag1_req1, dag1_sla1]
        assert manager._callback_to_execute[dag2_req1.full_filepath] == [dag2_req1]
        
        manager._add_callback_to_queue(dag1_sla2)
        
        assert manager._file_path_queue == collections.deque(
            [dag2_req1.full_filepath, dag1_req1.full_filepath]
        )
        assert manager._callback_to_execute[dag1_req1.full_filepath] == [dag1_req1, dag1_sla1]
        
        manager._add_callback_to_queue(dag1_req2)
        
        assert manager._file_path_queue == collections.deque(
            [dag1_req1.full_filepath, dag2_req1.full_filepath]
        )
        assert manager._callback_to_execute[dag1_req1.full_filepath] == [dag1_req1, dag1_sla1, dag1_req2]
class TestDagFileProcessorAgent:
    def setup_method(self):
        
        self.old_modules = dict(sys.modules)
    def teardown_method(self):
        
        
        remove_list = []
        for mod in sys.modules:
            if mod not in self.old_modules:
                remove_list.append(mod)
        for mod in remove_list:
            del sys.modules[mod]
    def test_reload_module(self):