ian-r-rose

ian-r-rose

ian-r-rose

#!/bin/bash
set -euxo pipefail

openssl genrsa 2048 | openssl pkcs8 -topk8 -v2 des3 -inform PEM -out $1.p8 -nocrypt
openssl rsa -in $1.p8 -pubout -out $1.pub

cat $1.p8
cat $1.pub

ian-r-rose

#!/bin/bash
set -euxo pipefail

openssl genrsa 2048 | openssl pkcs8 -topk8 -v2 des3 -inform PEM -out $1.p8 -passout pass:"${2}"
openssl rsa -in $1.p8 -pubout -out $1.pub -passin pass:"${2}"

cat $1.p8
cat $1.pub

ian-r-rose

ian-r-rose

import contextlib
import time

import coiled
import dask
import dask.dataframe as dd
import distributed
import pandas
from dask.datasets import timeseries

ian-r-rose

ian-r-rose

ian-r-rose

ian-r-rose

import datetime

import distributed
from distributed.diagnostics import SchedulerPlugin
from distributed.utils import key_split, key_split_group


class TaskGroupStatistics(SchedulerPlugin):
    def __init__(self):
        """Initialize the plugin"""