kushsharma

#!/usr/bin/env bash

set -Eeuo pipefail
trap cleanup SIGINT SIGTERM ERR EXIT

script_dir=$(cd "$(dirname "${BASH_SOURCE[0]}")" &>/dev/null && pwd -P)

usage() {
  cat <<EOF
Usage: $(basename "${BASH_SOURCE[0]}") [-h] [-v] [-f] -p param_value arg1 [arg2...]

kushsharma

'''
DAG for automatic scheduler steroids injection. 
This fixes Airflow scheduler leaving dag runs in running state although 
tasks are completed successfully.
This runs every day and refresh last 7 days of dags but if you want to run 
on ad-hoc basis refresh older dags, use manual trigger and pass start_range 
as a date like '2021-01-01T00:00:00Z'
'''

from typing import Any, Callable, Dict, Optional

kushsharma

gpg-agent setup

Need to setup gpg-agent first, on OSX I use keychain (it also does ssh-agent)

$ brew info keychain
keychain: stable 2.8.5
User-friendly front-end to ssh-agent(1)
https://www.funtoo.org/Keychain
/usr/local/Cellar/keychain/2.8.5 (7 files, 108.5KB) *

kushsharma

package metrics

import (
	"github.com/jackc/pgx/v4/pgxpool"
	"github.com/prometheus/client_golang/prometheus"
)

// PgxPoolStatPromCollector is a Prometheus collector for pgx metrics using prometheus.Collector interface
type PgxPoolStatPromCollector struct {
	db    *pgxpool.Pool

kushsharma

# make sure statsd is using localhost:8125 as host
nc -u -l 8125