| // Example that demonstrates some action that executes after a timeout has elapsed, which can be canceled. | |
| // | |
| // Per this caveat noted in the comment for time.Timer.Stop() (in go 1.23.3)... | |
| // For a func-based timer created with [AfterFunc](d, f), if t.Stop returns false, then the timer has already expired | |
| // and the function f has been started in its own goroutine; Stop does not wait for f to complete before returning. | |
| // If the caller needs to know whether f is completed, it must coordinate with f explicitly. | |
| // | |
| // ...the DoAfterUnlessCanceled function shown here satisfies "must coordinate with f explicitly" in a general-purpose way. | |
| // | |
| // The original inspiration for this solution was a need to prevent race conditions in logs that fire after a certain |
| import rich.progress | |
| import rich.style | |
| class ColorChangingBarColumn(rich.progress.BarColumn): | |
| """Like `rich.progress.BarColumn` but fades from red to green as progress moves from 0 to 100%""" | |
| def __init__(self, *args, **kwargs): | |
| super().__init__(*args, **kwargs) | |
| self.finished_style = rich.style.Style(color="rgb(0, 255, 0)") |
Demonstrates how to use stream-json and s3-readstream
to handle a stream of line-delimited JSON data provided by an S3 object.
When the default function of jsonl-s3-stream.ts is run, it will fetch a configured amount of data
(50 bytes in this example, which would be very slow in a real-world application)
of data from the configured S3 object. The source S3 object is expected to contain a fully-formed, valid JSON value.
My own customized version of tetriscurses.
Download tetris.zsh and run zsh /path/to/downloaded/tetris.zsh to play.
Arrow keys control the shapes. Press q to quit.
| #!/bin/bash | |
| # Parses terraform fmt diff and writes temp files that can be used to create suggestion comments | |
| tmpdir=$(mktemp -d -t terraform-fmt-suggestions.XXXXX) | |
| tmpfile="" | |
| source_file="" | |
| inchunk=false | |
| regex_header_start='^[-]{3} old/(.*)$' | |
| regex_chunk_start='^@@ [-]([0-9]+),([0-9]+) [+][0-9]+,[0-9]+ @@$' # Captures start line & total lines |
| """Republishes messages in an AWS SQS dead-letter queue (DLQ) | |
| Useful for moving messages in a DLQ back to a "normal" SQS queue | |
| (e.g. once bugs are fixed or initial error is otherwise resolved). | |
| Workflow: | |
| 1. Get a message from the configured source DLQ | |
| 2. Publish a new message to the configured destination queue, | |
| using the body of the message from #1 | |
| 3. After a successful publish, delete the message retrieved in #1 from the DLQ |
| package main | |
| import ( | |
| "flag" | |
| "sort" | |
| "strconv" | |
| "strings" | |
| "time" | |
| "github.com/teambition/rrule-go" |
| import functools | |
| import sys | |
| import time | |
| import boto3 | |
| import botocore | |
| from python_dynamodb_lock.python_dynamodb_lock import DynamoDBLockClient | |
| lock_client = DynamoDBLockClient(boto3.resource('dynamodb')) |
| import re | |
| import sys | |
| try: | |
| from github import Github | |
| except ImportError: | |
| print('You must install PyGithub in order to use this script!') | |
| print('Example: `pip install pygithub`') | |
| print('More info: https://github.com/PyGithub/PyGithub') | |
| sys.exit(1) |