A simple word count program built with ZIO and Apache Beam/Scio that demonstrates retry logic and error handling.
| 2 files: | |
| batch-1.xml | |
| <?xml version="1.0" encoding="UTF-8"?><root><order id="ord-555" region="UK"> | |
| <line product-id="p1" qty="3"/> | |
| </order><order id="ord-666" region="MARS"> | |
| <line product-id="p1" qty="1"/> | |
| <line product-id="p2" qty="2"/> | |
| <line product-id="p99" qty="1"/> |
| { | |
| "items": [ | |
| { "product":"Laptop", "qty":1, "line_total":1200 }, | |
| { "product":"Mouse", "qty":2, "line_total":100 }, | |
| { "error":"Product not found: p99", "product":"UNKNOWN", "qty":1, "line_total":0 } | |
| ], | |
| "total_cost": 1300, | |
| "order_id": "ord-666", | |
| "tax_rate": 0 | |
| } |
| import pandas as pd | |
| import plotly.graph_objects as go | |
| import gradio as gr | |
| from io import StringIO | |
| def create_interactive_bitcoin_chart(csv_text=None): | |
| """Create interactive Bitcoin volume chart from CSV data""" | |
| try: | |
| if csv_text and csv_text.strip(): |
| import gradio as gr | |
| import numpy as np | |
| import spaces | |
| import torch | |
| import random | |
| from PIL import Image | |
| from diffusers import FluxKontextPipeline | |
| from diffusers.utils import load_image |
https://huggingface.co/spaces/Fancellu/Kokoro-TTS-Zero-CPU
To run from docker
docker run -it -p 7860:7860 --platform=linux/amd64 registry.hf.space/fancellu-kokoro-tts-zero-cpu:latest python app.py
https://huggingface.co/spaces/Fancellu/bark-pytorch2.6-compatible
This solves the PyTorch 2.6 breaking change where weights_only=True became the default, causing issues with older model files that contain non-tensor objects, with monkey patch patched_load()
Updated to Python 3.11, latest Gradio, and requirements.txt
If you have a GPU, you can run from Docker Desktop directly
docker run -it -p 7860:7860 --gpus=all --platform=linux/amd64 registry.hf.space/fancellu-bark-pytorch2-6-compatible:latest python app.py
| import zio._ | |
| import scala.{ Console => SConsole } | |
| import scala.io.StdIn | |
| import java.io.{ BufferedReader, IOException } | |
| import scala.util.Try | |
| object InterruptableReadLine extends ZIOAppDefault { | |
| def altReadLine(reader: BufferedReader = SConsole.in) = | |
| ZIO |
| import zio._ | |
| object FakeConsoleExample extends ZIOAppDefault { | |
| private val program = ZIO.serviceWithZIO[Console] { console => | |
| for { | |
| _ <- console.printLine("Going to the grocery store") | |
| input <- console.readLine("How are you? ") | |
| _ <- console.printLine(s"You said: $input") | |
| } yield () |
| package main | |
| import ( | |
| "fmt" | |
| "math/rand" | |
| "sync" | |
| "time" | |
| "unsafe" | |
| ) |