This is a simple configuration to have AUDITOR act as an APEL client for HTCondor. In this setup the entire AUDITOR+APEL chain runs a separate instance directly on each CE. You also need to configure the AUDITOR core and its PostgreSQL database.
If you want to run the toolchain from a different host (say the Condor Negotiator), adjust the schedd_names to cover all the condor submit nodes / CEs.
If you want to support subsites, adjust the various site entries in both configurations.
| from typing import Iterable, NamedTuple | |
| import argparse | |
| from pathlib import Path | |
| import re | |
| import socket | |
| import subprocess | |
| import time | |
| CLI = argparse.ArgumentParser() | |
| CLI.add_argument("SLOT", help=r"slot identifier as \d+_\d+") |
| #!/usr/bin/python3 | |
| from typing import Generator | |
| import argparse | |
| import configparser | |
| import contextlib | |
| import datetime | |
| import pathlib | |
| import tempfile | |
| import subprocess |
| diff -cB --recursive production/usr/lib/python2.7/site-packages/apel/db/__init__.py patched/usr/lib/python2.7/site-packages/apel/db/__init__.py | |
| *** production/usr/lib/python2.7/site-packages/apel/db/__init__.py 2021-03-22 17:42:15.000000000 +0100 | |
| --- patched/usr/lib/python2.7/site-packages/apel/db/__init__.py 2023-04-05 10:39:54.000000000 +0200 | |
| *************** | |
| *** 15,21 **** | |
| ''' | |
| LOGGER_ID = "apeldb" | |
| ! JOB_MSG_HEADER = "APEL-individual-job-message: v0.3" | |
| SUMMARY_MSG_HEADER = "APEL-summary-job-message: v0.2" |
| v = "Hello World" | |
| def scope(): | |
| global v | |
| try: | |
| 1/0 | |
| except ZeroDivisionError as v: | |
| pass | |
| print(v) |
| def slot_get(ob: object, field: str): | |
| tp = type(ob) | |
| try: | |
| field = tp.__dict__[field] | |
| except KeyError: | |
| return getattr(super(tp, ob), field) | |
| else: | |
| try: | |
| descriptor_get = field.__get__ | |
| except AttributeError: |
| import asyncio | |
| import time | |
| async def no_op(): | |
| return | |
| async def main_gather(count): | |
| await asyncio.gather(*(asyncio.gather(no_op()) for _ in range(count))) |
| # Measuring < 00 | X | 00 >, < 01 | X | 00 >, < 10 | X | 00 >, < 11 | X_0 | 00 > | |
| from qiskit import QuantumCircuit | |
| from qiskit.providers.aer import QasmSimulator | |
| import time | |
| # Use Aer's qasm_simulator | |
| simulator = QasmSimulator() | |
| # Circuit setup | |
| circuit = QuantumCircuit(2) # |00> |
| """ | |
| Basic "Decoscriptor" example | |
| """ | |
| from decoscriptor import anydeco | |
| @anydeco | |
| def art(fun, *args, **kwargs): | |
| print("Big Whoop and a bottle of", args, kwargs) | |
| print("Fun is set to", getattr(fun, "__self__", "<unbound>")) | |
| return fun(*args, **kwargs) |
| from contextlib import contextmanager | |
| class Optimizer: | |
| def __init__(self, weight: int): | |
| self.weight = weight | |
| def step(self, num): | |
| num = self.calculate(num) | |
| return self.apply(num) |