Based off https://gist.github.com/millerdev/547bac773483402554797e578fbd238f
export CONTAINER_NAME=open-chat-studio-db-1
export VOLUME_NAME=open-chat-studio_postgres_data
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 |
{ | |
"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": { |
""" | |
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 |
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") |
Based off https://gist.github.com/millerdev/547bac773483402554797e578fbd238f
export CONTAINER_NAME=open-chat-studio-db-1
export VOLUME_NAME=open-chat-studio_postgres_data