airhorns

Filtering Shopify webhooks

Shopify allows you to filter the events that trigger a webhook for your application. There's two ways to filter webhooks in Shopify:

• limit which records are delivered to your app, which you can do with a webhook filter
• limit which fields of each record are delivered to your app, which you can do with an includeFields list

Both of these strategies can be used individually or together to limit the number of webhook Shopify sends to your app, and lower your total Gadget compute time.

Webhook filters

airhorns

diff --git a/dist/traceable.cjs b/dist/traceable.cjs
index e28a67a3d8a5ad543aff6a565c9fd93824b6bc31..3981c280d572d671de3bd202504feb1f4cd0c7d6 100644
--- a/dist/traceable.cjs
+++ b/dist/traceable.cjs
@@ -377,20 +377,25 @@ function traceable(wrappedFunc, config) {
                 });
                 return tappedStream;
             }
-            async function* wrapAsyncIteratorForTracing(iterator, snapshot) {
+            async function* wrapAsyncGeneratorForTracing(iterable, snapshot) {

airhorns

/**
 * Bigtable schema layout for concurrency ticket managment
 * One key per queue shard to store the current list of holders, like `holders#<some-hash>#e:environmentId#q:queueName#s:shard`
 *  - queue id is the row key
 *  - shard id that splits up high concurrency queues for one tenant into many different shards, currently running with shards of size 20, so a tenant with 200 max conurrency gets 10 shards
 *  - `agg:holderCount` column containing the number of current holders
 *  - dynamic columns per current holder, using the particpant id as the column qualifier, having the workflowid as a value
 *  - hash is added up front to ensure that shards for the same tenant with correlated load go to different tablets
 *
 * One key per requester to store the list of waiting tickets, like `req#<some-hash>#e:environmentId#q:queueName#s:shard#priorityScore#enqueuedTimestamp#requesterId`

airhorns

/* eslint-disable no-console */
import type { AgentAction, AgentFinish } from "@langchain/core/agents";
import { BaseCallbackHandler } from "@langchain/core/callbacks/base";
import type { Document } from "@langchain/core/documents";
import type { Serialized } from "@langchain/core/load/serializable";
import {
  AIMessage,
  AIMessageChunk,
  BaseMessage,
  ChatMessage,

airhorns

// what would be really annoying to do
const result = await gpt4oMini.withConfig({callbacks: [BraintrustCallbackHandler]}).withStructuredOutput( //...

// what would be much better
export const gpt4oMini = new ChatOpenAI({
  model: "gpt-4o-mini",
  callbacks: [BraintrustCallbackHandler],
  ...retryConfig,
});

airhorns

const strictSchemaCache = new WeakMap<ZodSchema, ZodSchema>();

const strictZodSchema = (schema: ZodSchema): ZodSchema => {
  if (schema instanceof ZodObject) {
    const shape = schema.shape;
    const newShape: any = {};
    for (const key in shape) {
      const fieldSchema = shape[key];
      if (key == "default" && fieldSchema instanceof ZodOptional && fieldSchema.unwrap() instanceof ZodAny) {
        continue;

airhorns

function toast(text, delay){
  var div = document.createElement("div");
  div.style.position = "fixed";
  div.style.maxWidth = "80%";
  div.style.color = "white";
  div.style.boxSizing = "border-box";
  div.style.background = "rgba(0,0,0,0.76)";
  div.style.padding = "0.8em 2.618em";
  div.style.bottom = '9%';
  div.style.left = '3%';

airhorns

rip" "-dynamiclib" "-Wl,-dylib" "-nodefaultlibs" "--ld-path=/nix/store/cg869jlpzrh5xgc0hcll7risc5gsk611-mold-2.1.0/bin/mold"
       >   = note: clang-11: error: unsupported option '--ld-path=/nix/store/cg869jlpzrh5xgc0hcll7risc5gsk611-mold-2.1.0/bin/mold'
       >
       >
       > error: could not compile `jsonpath_lib` (lib) due to previous error
       > warning: build failed, waiting for other jobs to finish...

airhorns

import { assignInputs, validateAndSave } from "gadget";

/**
 * Run Action code for create on post
 * @param { import("gadget").CreatePostActionContext } context - Everything for running this action handler, like the api client, current record, params, etc. More on effect context: https://docs.gadget.dev/guides/extending-with-code#effect-context
 */
export async function run({ api, record, inputs }) {
  assignInputs(record, inputs);
  await validateAndSave(record);
}

airhorns

00:56:50  Encountered an error:
module 'isolate_proto' has no attribute 'RegisterCronResult'
00:56:50  Traceback (most recent call last):
  File "/Users/airhorns/Library/Caches/pypoetry/virtualenvs/warehouse-ACxaxuaC-py3.9/lib/python3.9/site-packages/dbt/main.py", line 136, in main
    results, succeeded = handle_and_check(args)
  File "/Users/airhorns/Library/Caches/pypoetry/virtualenvs/warehouse-ACxaxuaC-py3.9/lib/python3.9/site-packages/dbt/main.py", line 206, in handle_and_check
    task, res = run_from_args(parsed)
  File "/Users/airhorns/Library/Caches/pypoetry/virtualenvs/warehouse-ACxaxuaC-py3.9/lib/python3.9/site-packages/dbt/main.py", line 233, in run_from_args
    task = parsed.cls.from_args(args=parsed)
  File "/Users/airhorns/Library/Caches/pypoetry/virtualenvs/warehouse-ACxaxuaC-py3.9/lib/python3.9/site-packages/dbt/task/base.py", line 163, in from_args