rzeigler

# started on Wed Mar  4 17:16:24 2026


 Performance counter stats for '.venv/bin/python profiling/borg_job_overhead.py --input /home/ryanzeigler/Pictures --output /junk/test10':

    98,921,646,254      task-clock                       #    0.625 CPUs utilized             
           135,850      context-switches                 #    1.373 K/sec                     
             8,049      cpu-migrations                   #   81.367 /sec                      
         1,421,247      page-faults                      #   14.367 K/sec                     
 1,154,065,943,913      instructions                     #    2.14  insn per cycle            

rzeigler

# started on Wed Mar  4 16:51:19 2026


 Performance counter stats for '.venv/bin/python profiling/borg_job_overhead.py --input /home/ryanzeigler/Pictures --output /junk/test10':

    99,975,982,741      task-clock                       #    0.708 CPUs utilized             
           130,738      context-switches                 #    1.308 K/sec                     
             8,696      cpu-migrations                   #   86.981 /sec                      
         1,421,163      page-faults                      #   14.215 K/sec                     
 1,154,841,160,542      instructions                     #    2.12  insn per cycle            

rzeigler

import cats.Monad
import cats.syntax.all._

import scala.collection.immutable.SortedMap

final case class MatrixVar(elem: String, map: SortedMap[String, String]) {
  def render: String = {
    val parts = map.toList.map(pair => show"${pair._1}=${pair._2}").intercalate(";")
    show"$elem;$parts"
  }

rzeigler

  private def detectStall[F[_]: Concurrent: Timer, A]: Pipe[F, A, A] = {
    val currentTime = Sync[F].delay(OffsetDateTime.now())
    (stream: Stream[F, A]) =>
      Stream.eval(currentTime).flatMap { startTime =>
        Stream.eval(Ref[F].of(startTime)).flatMap { lastChunkSeen =>
          val watchdog = Stream
            .fixedRate(30.seconds)
            .evalMap(_ => (currentTime, lastChunkSeen.get).tupled)
            .ensure(new RuntimeException("pipeline appears to have stalled"))({
              case (now, lastChunk) =>

rzeigler

import * as http from "http";
import { ReaderTaskEither } from "fp-ts/lib/ReaderTaskEither"
import { TaskEither, fromIO } from "fp-ts/lib/TaskEither";
import { IO } from "fp-ts/lib/IO";
import { Task } from "fp-ts/lib/Task";
import axios, { AxiosInstance } from 'axios';
import { Either, left, right } from "fp-ts/lib/Either";

export type Logger = (s: string) => TaskEither<never, void>;

rzeigler

package com.github.rzeigler.reqs

import cats._
import cats.implicits._
import cats.effect._
import cats.effect.implicits._
import org.http4s.client.blaze._
import org.http4s.client._
import org.http4s.Uri
import cats.temp.par._

rzeigler

// Future versions of Hyper may add additional config options,
// which will not automatically be merged into this file.
// See https://hyper.is#cfg for all currently supported options.

module.exports = {
  config: {
    // default font size in pixels for all tabs
    fontSize: 14,

    // font family with optional fallbacks

rzeigler

import Control.Monad.Free
import Control.Monad.State.Lazy

data TerminalOp a = ReadLine (String -> a) | WriteLine String a

instance Functor TerminalOp where
  fmap f (ReadLine g) = ReadLine (f . g)
  fmap f (WriteLine s a) = WriteLine s (f a)

type TerminalIO a = Free TerminalOp a