swyx.io swyxio

## scrape.js

const { exec } = require('child_process');


// exec(`
// git log --reverse -- /Users/swyx/Desktop/Work/airbyte/airbyte-integrations/connectors/destination-amazon-sqs | awk 'NR>1 {print last} {last=$0}; /^commit/ && ++c==2{exit}'
// `, (err, stdout, stderr) => {
//   if (err) {
//     // node couldn't execute the command
//     return;

## gist:135136c1217b038e4b897415845e8150
1. Introduction

2. What are Data Nets?

3. Data Nets vs. Data Mesh

4. Data Nets vs. Data Contract

5. When do you need a Data Net?

## openaiscript.py

# https://beta.openai.com/docs/libraries
import os
import openai
import yaml

# Load your API key from an environment variable or secret management service
openai.api_key = os.getenv("OPENAI_API_KEY")


## contribs.js
[
  {
    "login": "cgardens",
    "id": 9092207,
    "node_id": "MDQ6VXNlcjkwOTIyMDc=",
    "avatar_url": "https://avatars.githubusercontent.com/u/9092207?v=4",
    "gravatar_id": "",
    "url": "https://api.github.com/users/cgardens",
    "html_url": "https://github.com/cgardens",
    "followers_url": "https://api.github.com/users/cgardens/followers",

## overcast.opml
<?xml version="1.0"?>
<opml version="1.0"><head><title>Overcast Podcast Subscriptions</title></head><body>
<outline type="rss"
  text="Editor's Picks from The Economist" title="Editor's Picks from The Economist"
  xmlUrl="https://rss.acast.com/theeconomisteditorspicks"
  htmlUrl="http://www.economist.com/"/>
<outline type="rss"
  text="The History of English Podcast" title="The History of English Podcast"
  xmlUrl="https://historyofenglishpodcast.com/feed/podcast/"
  htmlUrl="https://historyofenglishpodcast.com/"/>

## 01 - sample workflow.ts
import * as wf from '@temporalio/workflow';
import differenceInMilliseconds from 'date-fns/differenceInMilliseconds';
import type * as activities from './activities';
import { sub } from 'date-fns'

const {
  doMaintenance,
  notifySubscribers
} = wf.proxyActivities<typeof activities>({
  // remember to adjust timeouts!

## AutoHotkey.ahk
Settitlematchmode, 2


F12::
winmove, A,, 1,1,600,600
return

#IfWinActive, Microsoft Word
::sigma::
	;Send {Backspace 1}

## extra.css
.site-intro {
  font-size: 1.25rem;
    width: 60ch;
    margin: 0 auto;
}

.site-credits {
    position: fixed;
    width: 100vw;
    bottom: 0;

## workflow apis tweak.md

      
              1 file
            
          
              0 forks
            
          
              6 comments
            
          
              0 stars
            
          
                swyxio
                / workflow apis tweak.md
            
            
              Last active
              October 25, 2021 18:53
            
              
                workflow apis tweak.md
              
          
      View workflow apis tweak.md
  
      
    now that we have a cohesive look at workflow APIs, some issues remain:

createActivityHandle isnt really a handle, in the way that createWorkflowHandle and createChildWorkflowHandle are. it returns a function that you call.

users are confused by the proxy destructure which a very fancy way of doing type safety and ensuring consistent naming


defineSignal/Query dont add much value since they just create an object

extra setListener api that is doing the real work, basically 2 different functions branching by def.type


just taking another crack at api design.
simplified query and signal api

  
## sample.go
func mainWorkflow(ctx workflow.Context, userId) error {
		// ...
		selector.AddReceive(signalChannel, func(c workflow.ReceiveChannel, more bool) {
				c.Receive(ctx, &signalVal) // receive user signals!
		})
		timerFuture := workflow.NewTimer(childCtx, 30 * time.Day) // sleep for 30 days!
		selector.AddFuture(timerFuture, func(f workflow.Future) {
				_ = workflow.ExecuteActivity(ctx, SendEmailActivity).Get(ctx, nil) // timeouts and retries!
		})
		// Scale to Millions + Write Tests + Encrypt Data + Migrate Versions + ...

	const { exec } = require('child_process');


	// exec(`
	// git log --reverse -- /Users/swyx/Desktop/Work/airbyte/airbyte-integrations/connectors/destination-amazon-sqs \| awk 'NR>1 {print last} {last=$0}; /^commit/ && ++c==2{exit}'
	// `, (err, stdout, stderr) => {
	// if (err) {
	// // node couldn't execute the command
	// return;
	1. Introduction

	2. What are Data Nets?

	3. Data Nets vs. Data Mesh

	4. Data Nets vs. Data Contract

	5. When do you need a Data Net?

	# https://beta.openai.com/docs/libraries
	import os
	import openai
	import yaml

	# Load your API key from an environment variable or secret management service
	openai.api_key = os.getenv("OPENAI_API_KEY")
	[
	{
	"login": "cgardens",
	"id": 9092207,
	"node_id": "MDQ6VXNlcjkwOTIyMDc=",
	"avatar_url": "https://avatars.githubusercontent.com/u/9092207?v=4",
	"gravatar_id": "",
	"url": "https://api.github.com/users/cgardens",
	"html_url": "https://github.com/cgardens",
	"followers_url": "https://api.github.com/users/cgardens/followers",
	<?xml version="1.0"?>
	<opml version="1.0"><head><title>Overcast Podcast Subscriptions</title></head><body>
	<outline type="rss"
	text="Editor's Picks from The Economist" title="Editor's Picks from The Economist"
	xmlUrl="https://rss.acast.com/theeconomisteditorspicks"
	htmlUrl="http://www.economist.com/"/>
	<outline type="rss"
	text="The History of English Podcast" title="The History of English Podcast"
	xmlUrl="https://historyofenglishpodcast.com/feed/podcast/"
	htmlUrl="https://historyofenglishpodcast.com/"/>
	import * as wf from '@temporalio/workflow';
	import differenceInMilliseconds from 'date-fns/differenceInMilliseconds';
	import type * as activities from './activities';
	import { sub } from 'date-fns'

	const {
	doMaintenance,
	notifySubscribers
	} = wf.proxyActivities<typeof activities>({
	// remember to adjust timeouts!
	Settitlematchmode, 2


	F12::
	winmove, A,, 1,1,600,600
	return

	#IfWinActive, Microsoft Word
	::sigma::
	;Send {Backspace 1}
	.site-intro {
	font-size: 1.25rem;
	width: 60ch;
	margin: 0 auto;
	}

	.site-credits {
	position: fixed;
	width: 100vw;
	bottom: 0;
	func mainWorkflow(ctx workflow.Context, userId) error {
	// ...
	selector.AddReceive(signalChannel, func(c workflow.ReceiveChannel, more bool) {
	c.Receive(ctx, &signalVal) // receive user signals!
	})
	timerFuture := workflow.NewTimer(childCtx, 30 * time.Day) // sleep for 30 days!
	selector.AddFuture(timerFuture, func(f workflow.Future) {
	_ = workflow.ExecuteActivity(ctx, SendEmailActivity).Get(ctx, nil) // timeouts and retries!
	})
	// Scale to Millions + Write Tests + Encrypt Data + Migrate Versions + ...