maxfischer2781

import pyparsing as pp
from pyparsing.diagram import to_railroad, railroad_to_html
import tempfile
import webbrowser

pp.ParserElement.enable_left_recursion()

# named references
expr = pp.Forward().setName("expr")
add_sub = pp.Forward().setName("add_sub")

maxfischer2781

#!/usr/bin/env python3
from typing import BinaryIO
import socket
import argparse
import pathlib
import struct
import time


CLI = argparse.ArgumentParser(

maxfischer2781

class Number:
    def __new__(cls, literal):
        for scls in cls.__subclasses__():
            try:
                return scls(literal)
            except (TypeError, ValueError):
                pass
        raise TypeError("The path to hell is paved with incomplete examples")
    
    # here be numerical operations!

maxfischer2781

"""
Script to recreate missing APEL blah/batch records from a condor history.d directory
"""
from typing import TextIO, TypeVar, List
import argparse
import pathlib
import subprocess
import os
import threading
import tempfile

maxfischer2781

from __future__ import annotations

from abc import ABC, abstractmethod
from typing import Generic, TypeVar

R = TypeVar('R', bound='Runner')
T = TypeVar('T')  # result type


class Command(ABC, Generic[T, R]):

maxfischer2781

Notes on using HTCondor-CE with APEL accounting for WLCG

These are tales of An Admin getting APEL+HTCondor-CE to work at GridKa/FZK Tier 1.

As background information, see

• the HTCondor-CE documentation
• the HtCondorCe Accounting notes

Setting up HTCondor-CE for APEL

maxfischer2781

#!/bin/bash -l
#
# Wrapper when executing condor jobs
# Run jobs via `bash -l` to force sourcing a login shell including all /etc/profile.d/*.sh scripts
#
exec "$@"

maxfischer2781

#!/usr/bin/env python3
from typing import NamedTuple, Iterable, Dict, List

import argparse
import pathlib
import re


CLI = argparse.ArgumentParser()
CLI.add_argument(

maxfischer2781

#!/usr/bin/env python3
from typing import Dict


def switch(cases: Dict[str, str], default='UNDEFINED', separator='\n'):
    # ["IfThenElse(ac, am", "IfThenElse(bc, bm", "IfThenElse(cc, cm", ...]
    switch_expression = separator.join(
        f"IfThenElse({condition}, {on_match},"
        for condition, on_match in cases.items()
    )

maxfischer2781

from typing import NamedTuple, Optional, Deque, Any, Dict, AsyncIterable

from usim import Pipe, instant
from collections import deque
from usim._primitives.notification import Notification


class MonitoredPipeInfo(NamedTuple):
    requested_throughput: float
    available_throughput: float