elijahbenizzy

from hamilton.async_driver import Builder
from hamilton_sdk import adapters

tracker = adapters.AsyncHamiltonTracker(
    project_id=8,
    username="elijah@dagworks.io",
    dag_name="joke_dag",
)

dr = (

elijahbenizzy

from hamilton.async_driver import Builder

dr = await (
    Builder()
    .with_modules(async_functions)
    .build()
)

await dr.execute(["joke_response"], inputs={"topic" : "federal reserve"})

elijahbenizzy

from hamilton.async_driver import AsyncBuilder
dr = (
    AsyncBuilder()
    .with_modules(module_from_above)
    .build()
)

await dr.execute(
    joke_response, 
    inputs={"topic" : "the federal reserve"}

elijahbenizzy

def llm_client() -> openai.AsyncOpenAI:
    return openai.AsyncOpenAI()

def joke_prompt(topic: str) -> str:
    return (
        f"Tell me a short joke about {topic}"
    )

def joke_messages(
        joke_prompt: str) -> List[dict]:

elijahbenizzy

async def dont_block_control_flow():
    result_1 = await complex_http_call()
    result_2 = await complex_system_call(result_1)
    return result_2

data_loaded = await dont_block_control_flow()

elijahbenizzy

# python 3.12

"""
Hamilton demo.
"""

import sys

import pprint

elijahbenizzy

elijahbenizzy

<div className="flex-1 overflow-y-auto p-4 hide-scrollbar" id={VIEW_END_ID}>
  {displayedChatHistory.map((message, i) => (
    <ChatMessage
      message={message}
      key={i}
    />
  ))}
  {isChatWaiting && (
    <ChatMessage
      message={{

elijahbenizzy

type Event = {
  type: 'delta' | 'chat_history';
};

type ChatMessageEvent = Event & {
  value: string;
};

type ChatHistoryEvent = Event & {
  value: ChatItem[];

elijahbenizzy

while (true) {
    const result = await reader.read();
    if (result.done) {
      break;
    }
    const message = decoder.decode(result.value, { stream: true });
    message
      .split('data: ')
      .slice(1)
      .forEach((item) => {