looselycoupled

import random
from pprint import pprint

from google.cloud import spanner

# Initialize Spanner client
spanner_client = spanner.Client(project='test-project')
instance = spanner_client.instance('test-instance')
database = instance.database('test-database')

looselycoupled

package main

import (
	"crypto/ed25519"
	"crypto/rand"
	"encoding/json"
	"fmt"
	"time"

	"github.com/lestrrat-go/jwx/v2/jwa"

looselycoupled

How to push tagged Docker releases to Google Artifact Registry with a GitHub Action

Here's how I configured a GitHub Action so that a new version issued by GitHub's release interface will build a Dockerfile, tag it with the version number and upload it to Google Artifact Registry.

Before you attempt the steps below, you need the following:

• A GitHub repository that contains a working Dockerfile
• The Google Cloud SDK tool gcloud installed and authenticated

Create a Workload Identity Federation

looselycoupled

#!/usr/bin/env python
"""
Template for RSS exercise
"""
##########################################################################
## Imports
##########################################################################

import os
import re

looselycoupled

package foo

import (
	"github.com/ProtonMail/gopenpgp/v2/crypto"
	"github.com/ProtonMail/gopenpgp/v2/helper"
	"github.com/stretchr/testify/require"
	"testing"
)

func TestGenerateGPGKeys(t *testing.T) {

looselycoupled

package main

import (
	"crypto/sha256"
	"encoding/hex"
	"fmt"
	log "github.com/sirupsen/logrus"
	"github.com/urfave/cli/v2"
	"io"
	"os"

looselycoupled

# vim:ft=zsh ts=2 sw=2 sts=2
#
# Based on agnoster's Theme - https://gist.github.com/3712874
# A Powerline-inspired theme for ZSH
#
# # README
#
# In order for this theme to render correctly, you will need a
# [Powerline-patched font](https://github.com/Lokaltog/powerline-fonts).
# Make sure you have a recent version: the code points that Powerline

looselycoupled

import ray
from collections import Counter
import socket
from pprint import pprint

ray.init("auto")

@ray.remote
def f(x):
    return x + (socket.gethostname(), )

looselycoupled

looselycoupled

import re
import subprocess
from tabulate import tabulate

def get_nodes():
    output = subprocess.run("kubectl get nodes".split(), stdout=subprocess.PIPE)
    text = output.stdout.decode("utf-8").split("\n")
    return [(re.split("\s+", line)[0],re.split("\s+", line)[2]) for line in text[1:] if line]

def cluster_capacity():