ИИ-диджей, который сводит сам

# внутри библиотеки, по процессу на каждое из 16 ядер
pool = Pool()

r = allin1.analyze(src, demix_dir=tmp, device="cpu",
                   keep_byproducts=False,
                   multiprocess=False)

def stage_self_as_stems(path, tmp):
    """Подсовывает сам трек на все четыре канала — вместо разделения."""
    stem = os.path.splitext(os.path.basename(path))[0]
    dst = os.path.join(tmp, "htdemucs", stem)
    os.makedirs(dst, exist_ok=True)
    for name in ("vocals", "bass", "drums", "other"):
        subprocess.run(["ffmpeg", "-v", "error", "-y", "-i", path,
                        "-ac", "2", "-ar", "44100",
                        os.path.join(dst, name + ".wav")], check=True)

self._fill_queue()                      # очередь строится здесь…
if self._set_start_time <= 0:
    self._set_start_time = time.time()  # …а план вечера включается тут

if self._set_start_time <= 0:
    self._set_start_time = time.time()
self._fill_queue()

de = abs(energy - ref_energy)      # 85…468 против порогов 0.05…0.20
if   de < 0.05: s_ref_energy = 8
elif de < 0.12: s_ref_energy = 5
elif de < 0.20: s_ref_energy = 2
else:            s_ref_energy = -2   # срабатывало всегда

_mn_re, _mx_re = arc_energy_range        # реальный размах режима
if _mx_re > _mn_re:
    de = abs(energy - ref_energy) / (_mx_re - _mn_re)
else:
    de = abs(energy - ref_energy)

payload["ssm_sections"] = _segs       # разметка модели…
# …14 строк спустя, внутри другого метода:
payload["ssm_sections"] = merged.get("sections", [])

if payload.get("structure_source") != "allin1" or not payload.get("ssm_sections"):
    payload["ssm_sections"] = merged.get("sections", [])

# якорь — сам server.exe: в собранном виде путь к исходнику
# указывает внутрь архива, а модуль лежит рядом с программой
_exe_dir = _P(sys.executable).parent
for _cand in (
    _exe_dir / "allin1" / "allin1_run.exe",
    _exe_dir / "allin1_run.exe",
    SERVER_DIR / "allin1_run.exe",
):
    if _cand.exists():
        _ai1_exe = _cand
        break