{
"cells": [
{
"cell_type": "code",
"execution_count": 1,
"metadata": {},
"outputs": [],
"source": [
"%load_ext hamilton.plugins.jupyter_magic"
]
},
{
"cell_type": "code",
"execution_count": 2,
"metadata": {},
"outputs": [
{
"data": {
"image/svg+xml": [
"\n",
"\n",
"\n",
"\n",
"\n"
],
"text/plain": [
""
]
},
"metadata": {},
"output_type": "display_data"
}
],
"source": [
"%%cell_to_module -m test_module --display --rebuild-drivers\n",
"\n",
"from hamilton.function_modifiers import cache\n",
"import pandas as pd\n",
"from hamilton.caching import fingerprinting\n",
"from typing import Any\n",
"class CustomClass:\n",
" data = 3\n",
"\n",
"@fingerprinting.hash_value.register(CustomClass) # type: ignore[misc]\n",
"def hash_db_client_object(obj: CustomClass, *args: Any, **kwargs: Any) -> str:\n",
" \"\"\"Trick hamilton into caching data loading stage and avoid DB access.\"\"\"\n",
" return \"constant\"\n",
"\n",
"def A(c: CustomClass, some_value: int) -> int:\n",
" return some_value + 10 + c.data\n",
"\n",
"def B(c: CustomClass, some_value: int) -> int:\n",
" return some_value + 20 + c.data"
]
},
{
"cell_type": "code",
"execution_count": 3,
"metadata": {},
"outputs": [],
"source": [
"from hamilton import driver\n",
"import test_module\n",
"\n",
"\n",
"def get_driver(new_value):\n",
"\n",
" dr = (\n",
" driver.Builder()\n",
" .with_config({\"some_value\": new_value})\n",
" .with_modules(test_module)\n",
" .with_cache(path=\"./another\")\n",
" .build()\n",
" )\n",
" return dr"
]
},
{
"cell_type": "code",
"execution_count": 4,
"metadata": {},
"outputs": [
{
"name": "stderr",
"output_type": "stream",
"text": [
"Node `c` has unhashable result of type ``. Set `CachingBehavior.IGNORE` or register a versioning function to silence warning. Learn more: https://hamilton.dagworks.io/en/latest/concepts/caching/#caching-behavior\n",
"\n"
]
},
{
"data": {
"text/plain": [
"{'A': 113, 'B': 123}"
]
},
"execution_count": 4,
"metadata": {},
"output_type": "execute_result"
}
],
"source": [
"class_inst = test_module.CustomClass()\n",
"get_driver(100).execute([\"A\", \"B\"], inputs={\"c\": class_inst})"
]
},
{
"cell_type": "code",
"execution_count": 5,
"metadata": {},
"outputs": [
{
"name": "stderr",
"output_type": "stream",
"text": [
"Node `c` has unhashable result of type ``. Set `CachingBehavior.IGNORE` or register a versioning function to silence warning. Learn more: https://hamilton.dagworks.io/en/latest/concepts/caching/#caching-behavior\n",
"\n"
]
},
{
"data": {
"text/plain": [
"{'A': 213, 'B': 223}"
]
},
"execution_count": 5,
"metadata": {},
"output_type": "execute_result"
}
],
"source": [
"class_inst = test_module.CustomClass()\n",
"get_driver(200).execute([\"A\", \"B\"], inputs={\"c\": class_inst})"
]
}
],
"metadata": {
"kernelspec": {
"display_name": ".venv",
"language": "python",
"name": "python3"
},
"language_info": {
"codemirror_mode": {
"name": "ipython",
"version": 3
},
"file_extension": ".py",
"mimetype": "text/x-python",
"name": "python",
"nbconvert_exporter": "python",
"pygments_lexer": "ipython3",
"version": "3.12.8"
}
},
"nbformat": 4,
"nbformat_minor": 2
}