@@ 259,18 259,12 @@ def unprepare(engine, sid):
     return count
 
 
-def freeze_operations(engine, domain=None, domain_map=None,
-                      hostid=None):
+def freeze_operations(engine, domain=None, hostid=None):
     values = []
     if hostid is None:
         hostid = host()
 
-    if domain_map:
-        domain = domain_map.get(domain, domain)
-
     for (fdomain, fname), (func, timeout) in __task_registry__.items():
-        if domain_map:
-            fdomain = domain_map.get(fdomain, fdomain)
         if domain is not None and domain != fdomain:
             continue
         if timeout is not None:

          

@@ 268,20 268,6 @@ def test_worker_two_runs_nondfefault_dom
         assert t3.status == 'queued'
 
 
-def test_domain_map(engine, cleanup):
-    with engine.begin() as cn:
-        cn.execute('delete from rework.operation')
-
-    api.freeze_operations(engine, domain='nondefault',
-                          domain_map={'nondefault': 'fancy'}
-    )
-
-    with workers(engine, maxruns=1, domain='fancy'):
-        t1 = api.schedule(engine, 'run_in_non_default_domain')
-        t1.join()
-        assert t1.status == 'done'
-
-
 def test_task_rawinput(engine, cleanup):
     with workers(engine):
         t = api.schedule(engine, 'raw_input', rawinputdata=b'Babar')