Federico Minutoli DiTo97

machine learning researcher passionate in robotics, computer vision and NLP

DiTo97 / !importing.py

Last active February 16, 2024 02:28

A minimal collection of import utility functions

	import sys
	import typing


	if typing.TYPE_CHECKING:
	import types


	def srcfile_import(modpath: str, modname: str) -> "types.ModuleType":
	"""It imports a python module from its srcfile

DiTo97 / !savings-simulation.py

Last active December 30, 2024 16:10

savings simulation on poste.it options

DiTo97 / !spawning.py

Last active February 21, 2025 12:41

A collection of safe process and system utilities

	import logging
	import typing

	import psutil


	T = typing.TypeVar("T")


	def safe_execute(function: typing.Callable[..., T], args, *kwargs, timeout: int = 60) -> T:

DiTo97 / !database.py

Last active March 13, 2025 02:16

A feature-rich database model for use with SQLAlchemy's ORM abstraction

	import typing
	from uuid import UUID, uuid4
	from datetime import datetime, timezone
	from functools import partial
	from typing import Any

	from pydantic import BaseModel
	from sqlalchemy import select, func, sql
	from sqlalchemy.dialects.mysql import insert as mysql_insert
	from sqlalchemy.dialects.postgresql import insert as postgres_insert

DiTo97 / !vllm_rollout_spmd.py

Last active May 30, 2025 13:51

ReCall rollout with LangGraph's tool node as execution engine, https://github.com/Agent-RL/ReCall/tree/3d976d26ade4950bc491335bb80da1659424b3cb

	import asyncio
	import json
	import os
	import re
	import typing
	import uuid
	from contextlib import contextmanager
	from typing import Any

	import numpy as np

DiTo97 / !telemetry.py

Last active October 18, 2025 15:26

OpenTelemetry tracing utilities for any library.

	"""OpenTelemetry tracing utilities for any library.

	This module provides decorators to simplify the integration of OpenTelemetry
	tracing into Python applications. It offers `trace_function` for instrumenting
	individual functions (both synchronous and asynchronous) and `trace_class`
	for instrumenting multiple methods within a class.

	The tracer is initialized with the module name and version defined by
	`INSTRUMENTING_MODULE` ('<module>') and
	`INSTRUMENTING_MODULE_VERSION` ('<version>').

DiTo97 / a2a_distributed_queue.py

Last active October 18, 2025 15:18

A2A event queue and queue manager using Redis

	import asyncio
	import json
	import logging
	import uuid

	import redis.asyncio as redis

	from a2a.server.events.event_queue import EventQueue
	from a2a.server.events.queue_manager import (
	NoTaskQueue,

DiTo97 / sampling_methods_for_evaluation.py

Created November 13, 2025 00:09

efficient and reliable sampling methodologies for pass@k and pass^k evaluation

	import math
	import numpy as np
	from scipy.stats import beta
	from collections import defaultdict

	# ==============================================================================
	# 1. Metric Estimation Functions
	# ==============================================================================

	def pass_at_k_unbiased_estimator(n, c, k):

DiTo97 / safeasyncio.py

Last active November 18, 2025 01:26

A collection of utilities for safely executing asynchronous coroutines

	import asyncio
	from typing import Any, Coroutine


	class _AsyncThread(threading.Thread):
	"""helper thread class for running async coroutines in a separate thread"""

	def __init__(self, coroutine: Coroutine[Any, Any, Any]):
	self.coroutine = coroutine
	self.result = None