Skip to content

Instantly share code, notes, and snippets.

View snopoke's full-sized avatar

Simon Kelly snopoke

View GitHub Profile
import csv
import shutil
import gzip
from collections import Counter
from elasticsearch.exceptions import ConnectionTimeout
from corehq.util.timezones.utils import parse_date
path = '/home/cchq/form_dates'
try:
import os
import csv
import shutil
import gzip
from datetime import datetime, timedelta
from collections import Counter
from elasticsearch.exceptions import ConnectionTimeout
from corehq.util.timezones.utils import parse_date
from corehq.apps.es import FormES
@snopoke
snopoke / capability.json
Created March 10, 2023 14:56
FHIR capability statement
{
"resourceType": "CapabilityStatement",
"url": "https://www.commcarehq.org/a/<domain>/fhir/capability.json",
"name": "CommCare <domain>",
"title": "CommCare FHIR capability statement",
"status": "draft",
"date": "<dateTime>",
"publisher": "Dimagi",
"kind": "capability",
"implementation": {
@snopoke
snopoke / pipe_split_merge.py
Created March 20, 2024 15:24
Langchain runnable split / merge POC
"""
Demonstrate a method to create a pipeline that can handle dynamic splits in the pipeline based on the input type.
"""
import functools
import operator
from typing import Any
from langchain_core.callbacks import CallbackManagerForChainRun
from langchain_core.runnables import Runnable, RunnableConfig, RunnableLambda, RunnableSerializable, patch_config
from langchain_core.runnables.base import RunnableEach
@snopoke
snopoke / runnable_config.py
Created March 20, 2024 15:25
Langchain runnable configuration POC
import uuid
from typing import Generic, TypeVar
from langchain_core.callbacks import CallbackManagerForChainRun
from langchain_core.runnables import RunnableConfig
from langchain_core.runnables.base import RunnableSerializable
from langchain_core.runnables.utils import ConfigurableField
T = TypeVar("T")
@snopoke
snopoke / upgrade.md
Last active April 3, 2024 09:20
docker pg-upgrade / migrate