lukeorland

"""
Retrieve all the logs for a flow run.

E.g.

FLOW_RUN_ID=adff99c1-7dcf-40c1-bd1d-1c026ad930cb \
  python \
    notes-synced/snippets/fetch_flow_run_logs.py \
    print_concatenated_log_messages \
    $FLOW_RUN_ID \

lukeorland

#! /usr/bin/env zsh
# https://stackoverflow.com/questions/7726949/remove-tracking-branches-no-longer-on-remote/38404202#comment91928557_38404202

function git-prune-not-fully-merged-branches {
    git fetch
    git checkout main
    git branch -vv | grep ': gone]'|  grep -v "\*" | awk '{ print $1; }' | xargs -r git branch -d
    git checkout -
}

lukeorland

Keybase proof

I hereby claim:

• I am lukeorland on github.
• I am orluke (https://keybase.io/orluke) on keybase.
• I have a public key ASAwfXXw2gairO6ye-QxD5TIuBCWX3Eq5Jr2y45GZMj7Iwo

To claim this, I am signing this object:

lukeorland

from prefect import Flow, Parameter
from prefect.tasks.secrets import PrefectSecret

aws_secret = PrefectSecret(name=None) # initializes Task, unrelated to binding it within a Flow


with Flow("parameter_to_secret") as flow:
    aws_credentials_secret_name = Parameter(
        'aws_credentials_secret_name', default='AWS_CREDENTIALS',
    )

lukeorland

import prefect
from prefect import Flow, Parameter, task


@task
def func_factory():
    def func():
        prefect.context.get('logger').info('this is a func')

    return func

lukeorland

import inspect
import os


def get_dir_containing_this_file():
    return os.path.dirname(
        os.path.abspath(
            inspect.getframeinfo(
                inspect.currentframe()).filename))

lukeorland

import multiprocessing

pool = multiprocessing.Pool(processes=multiprocessing.cpu_count())
df['normalized_text'] = pool.map(normalize_text, df['text'])
pool.close() 
pool.join()

lukeorland

#!/usr/bin/env python3
import concurrent.futures
import time


def slumber(seconds):
    time.sleep(seconds)
    print("slept %s seconds" % seconds)

lukeorland

# -*- coding: utf-8 -*-
import argparse
import csv
import re

fields = ("Start Time", "End Time", "Activity", "Text", "Notes")


def parse_arguments():
    parser = argparse.ArgumentParser(description='')

lukeorland

Keybase proof

I hereby claim:

• I am lukeorland on github.
• I am orluke (https://keybase.io/orluke) on keybase.
• I have a public key whose fingerprint is 50F6 A605 06CC 59DF 715B 1F0F 1307 0B06 3F6B E0F7

To claim this, I am signing this object: