Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
49 changes: 49 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,3 +1,52 @@
### Change log [2026-01-06 15:06:26]
1. Item Updated: `verify_schema` (from version: `1.0.0` to `1.0.0`)

### Change log [2026-01-06 15:06:21]
1. Item Updated: `agent_deployer` (from version: `1.0.0` to `1.0.0`)
2. Item Updated: `histogram_data_drift` (from version: `1.0.0` to `1.0.0`)
3. Item Updated: `openai_proxy_app` (from version: `1.0.0` to `1.0.0`)
4. Item Updated: `vllm_module` (from version: `1.0.0` to `1.0.0`)
5. Item Updated: `count_events` (from version: `1.0.0` to `1.0.0`)
6. Item Updated: `evidently_iris` (from version: `1.0.0` to `1.0.0`)

### Change log [2026-01-06 15:06:12]
1. Item Updated: `test_classifier` (from version: `1.1.0` to `1.1.0`)
2. Item Updated: `sklearn_classifier` (from version: `1.2.0` to `1.2.0`)
3. Item Updated: `model_server_tester` (from version: `1.1.0` to `1.1.0`)
4. Item Updated: `azureml_serving` (from version: `1.1.0` to `1.1.0`)
5. Item Updated: `describe_dask` (from version: `1.2.0` to `1.2.0`)
6. Item Updated: `batch_inference` (from version: `1.8.0` to `1.8.0`)
7. Item Updated: `v2_model_server` (from version: `1.2.0` to `1.2.0`)
8. Item Updated: `gen_class_data` (from version: `1.3.0` to `1.3.0`)
9. Item Updated: `send_email` (from version: `1.2.0` to `1.2.0`)
10. Item Updated: `tf2_serving` (from version: `1.1.0` to `1.1.0`)
11. Item Updated: `aggregate` (from version: `1.4.0` to `1.4.0`)
12. Item Updated: `open_archive` (from version: `1.2.0` to `1.2.0`)
13. Item Updated: `describe` (from version: `1.4.0` to `1.4.0`)
14. Item Updated: `v2_model_tester` (from version: `1.1.0` to `1.1.0`)
15. Item Updated: `text_to_audio_generator` (from version: `1.3.0` to `1.3.0`)
16. Item Updated: `pii_recognizer` (from version: `0.4.0` to `0.4.0`)
17. Item Updated: `github_utils` (from version: `1.1.0` to `1.1.0`)
18. Item Updated: `sklearn_classifier_dask` (from version: `1.1.1` to `1.1.1`)
19. Item Updated: `azureml_utils` (from version: `1.4.0` to `1.4.0`)
20. Item Updated: `question_answering` (from version: `0.5.0` to `0.5.0`)
21. Item Updated: `structured_data_generator` (from version: `1.6.0` to `1.6.0`)
22. Item Updated: `arc_to_parquet` (from version: `1.5.0` to `1.5.0`)
23. Item Updated: `silero_vad` (from version: `1.4.0` to `1.4.0`)
24. Item Updated: `load_dataset` (from version: `1.2.0` to `1.2.0`)
25. Item Updated: `auto_trainer` (from version: `1.8.0` to `1.8.0`)
26. Item Updated: `feature_selection` (from version: `1.6.0` to `1.6.0`)
27. Item Updated: `translate` (from version: `0.3.0` to `0.3.0`)
28. Item Updated: `describe_spark` (from version: `1.1.0` to `1.1.0`)
29. Item Updated: `pyannote_audio` (from version: `1.3.0` to `1.3.0`)
30. Item Updated: `onnx_utils` (from version: `1.3.0` to `1.3.0`)
31. Item Updated: `batch_inference_v2` (from version: `2.6.0` to `2.6.0`)
32. Item Updated: `transcribe` (from version: `1.2.0` to `1.2.0`)
33. Item Updated: `model_server` (from version: `1.2.0` to `1.2.0`)
34. Item Updated: `mlflow_utils` (from version: `1.1.0` to `1.1.0`)
35. Item Updated: `noise_reduction` (from version: `1.1.0` to `1.1.0`)
36. Item Updated: `hugging_face_serving` (from version: `1.1.0` to `1.1.0`)

### Change log [2026-01-01 11:58:47]
1. New item created: `verify_schema` (version: `1.0.0`)

Expand Down
2 changes: 1 addition & 1 deletion functions/development/tags.json
Original file line number Diff line number Diff line change
@@ -1 +1 @@
{"kind": ["serving", "nuclio:serving", "job"], "categories": ["model-testing", "genai", "machine-learning", "data-generation", "NLP", "deep-learning", "utils", "data-preparation", "model-serving", "model-training", "monitoring", "audio", "data-analysis"]}
{"kind": ["nuclio:serving", "serving", "job"], "categories": ["NLP", "model-testing", "model-serving", "audio", "utils", "machine-learning", "deep-learning", "model-training", "data-analysis", "data-generation", "genai", "monitoring", "data-preparation"]}
36 changes: 28 additions & 8 deletions modules/development/agent_deployer/1.0.0/src/agent_deployer.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,17 @@
from mlrun.datastore.datastore_profile import (
DatastoreProfileV3io,
DatastoreProfileKafkaStream,
DatastoreProfileTDEngine,
)

# TimescaleDB support (mlrun >= 1.11), fallback to TDEngine for older versions
try:
from mlrun.datastore.datastore_profile import DatastoreProfilePostgreSQL

_USE_TIMESCALEDB = True
except ImportError:
from mlrun.datastore.datastore_profile import DatastoreProfileTDEngine

_USE_TIMESCALEDB = False
from mlrun.utils import logger


Expand Down Expand Up @@ -87,13 +96,24 @@ def configure_model_monitoring(self):
)
if mlconf.is_ce_mode():
mlrun_namespace = os.environ.get("MLRUN_NAMESPACE", "mlrun")
tsdb_profile = DatastoreProfileTDEngine(
name="tdengine-tsdb-profile",
user="root",
password="taosdata",
host=f"tdengine-tsdb.{mlrun_namespace}.svc.cluster.local",
port="6041",
)
if _USE_TIMESCALEDB:
tsdb_profile = DatastoreProfilePostgreSQL(
name="timescaledb-tsdb-profile",
user="postgres",
password="postgres",
host=f"timescaledb.{mlrun_namespace}.svc.cluster.local",
port="5432",
database="postgres",
)
else:
# Fallback for older mlrun versions
tsdb_profile = DatastoreProfileTDEngine(
name="tdengine-tsdb-profile",
user="root",
password="taosdata",
host=f"tdengine-tsdb.{mlrun_namespace}.svc.cluster.local",
port="6041",
)

stream_profile = DatastoreProfileKafkaStream(
name="kafka-stream-profile",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
mlrun==1.10.0-rc41
mlrun==1.10.0
pytest~=8.2
Original file line number Diff line number Diff line change
Expand Up @@ -164,8 +164,17 @@ <h1>Source code for agent_deployer.agent_deployer</h1><div class="highlight"><pr
<span class="kn">from</span><span class="w"> </span><span class="nn">mlrun.datastore.datastore_profile</span><span class="w"> </span><span class="kn">import</span> <span class="p">(</span>
<span class="n">DatastoreProfileV3io</span><span class="p">,</span>
<span class="n">DatastoreProfileKafkaStream</span><span class="p">,</span>
<span class="n">DatastoreProfileTDEngine</span><span class="p">,</span>
<span class="p">)</span>

<span class="c1"># TimescaleDB support (mlrun &gt;= 1.11), fallback to TDEngine for older versions</span>
<span class="k">try</span><span class="p">:</span>
<span class="kn">from</span><span class="w"> </span><span class="nn">mlrun.datastore.datastore_profile</span><span class="w"> </span><span class="kn">import</span> <span class="n">DatastoreProfilePostgreSQL</span>

<span class="n">_USE_TIMESCALEDB</span> <span class="o">=</span> <span class="kc">True</span>
<span class="k">except</span> <span class="ne">ImportError</span><span class="p">:</span>
<span class="kn">from</span><span class="w"> </span><span class="nn">mlrun.datastore.datastore_profile</span><span class="w"> </span><span class="kn">import</span> <span class="n">DatastoreProfileTDEngine</span>

<span class="n">_USE_TIMESCALEDB</span> <span class="o">=</span> <span class="kc">False</span>
<span class="kn">from</span><span class="w"> </span><span class="nn">mlrun.utils</span><span class="w"> </span><span class="kn">import</span> <span class="n">logger</span>


Expand Down Expand Up @@ -233,13 +242,24 @@ <h1>Source code for agent_deployer.agent_deployer</h1><div class="highlight"><pr
<span class="p">)</span>
<span class="k">if</span> <span class="n">mlconf</span><span class="o">.</span><span class="n">is_ce_mode</span><span class="p">():</span>
<span class="n">mlrun_namespace</span> <span class="o">=</span> <span class="n">os</span><span class="o">.</span><span class="n">environ</span><span class="o">.</span><span class="n">get</span><span class="p">(</span><span class="s2">"MLRUN_NAMESPACE"</span><span class="p">,</span> <span class="s2">"mlrun"</span><span class="p">)</span>
<span class="n">tsdb_profile</span> <span class="o">=</span> <span class="n">DatastoreProfileTDEngine</span><span class="p">(</span>
<span class="n">name</span><span class="o">=</span><span class="s2">"tdengine-tsdb-profile"</span><span class="p">,</span>
<span class="n">user</span><span class="o">=</span><span class="s2">"root"</span><span class="p">,</span>
<span class="n">password</span><span class="o">=</span><span class="s2">"taosdata"</span><span class="p">,</span>
<span class="n">host</span><span class="o">=</span><span class="sa">f</span><span class="s2">"tdengine-tsdb.</span><span class="si">{</span><span class="n">mlrun_namespace</span><span class="si">}</span><span class="s2">.svc.cluster.local"</span><span class="p">,</span>
<span class="n">port</span><span class="o">=</span><span class="s2">"6041"</span><span class="p">,</span>
<span class="p">)</span>
<span class="k">if</span> <span class="n">_USE_TIMESCALEDB</span><span class="p">:</span>
<span class="n">tsdb_profile</span> <span class="o">=</span> <span class="n">DatastoreProfilePostgreSQL</span><span class="p">(</span>
<span class="n">name</span><span class="o">=</span><span class="s2">"timescaledb-tsdb-profile"</span><span class="p">,</span>
<span class="n">user</span><span class="o">=</span><span class="s2">"postgres"</span><span class="p">,</span>
<span class="n">password</span><span class="o">=</span><span class="s2">"postgres"</span><span class="p">,</span>
<span class="n">host</span><span class="o">=</span><span class="sa">f</span><span class="s2">"timescaledb.</span><span class="si">{</span><span class="n">mlrun_namespace</span><span class="si">}</span><span class="s2">.svc.cluster.local"</span><span class="p">,</span>
<span class="n">port</span><span class="o">=</span><span class="s2">"5432"</span><span class="p">,</span>
<span class="n">database</span><span class="o">=</span><span class="s2">"postgres"</span><span class="p">,</span>
<span class="p">)</span>
<span class="k">else</span><span class="p">:</span>
<span class="c1"># Fallback for older mlrun versions</span>
<span class="n">tsdb_profile</span> <span class="o">=</span> <span class="n">DatastoreProfileTDEngine</span><span class="p">(</span>
<span class="n">name</span><span class="o">=</span><span class="s2">"tdengine-tsdb-profile"</span><span class="p">,</span>
<span class="n">user</span><span class="o">=</span><span class="s2">"root"</span><span class="p">,</span>
<span class="n">password</span><span class="o">=</span><span class="s2">"taosdata"</span><span class="p">,</span>
<span class="n">host</span><span class="o">=</span><span class="sa">f</span><span class="s2">"tdengine-tsdb.</span><span class="si">{</span><span class="n">mlrun_namespace</span><span class="si">}</span><span class="s2">.svc.cluster.local"</span><span class="p">,</span>
<span class="n">port</span><span class="o">=</span><span class="s2">"6041"</span><span class="p">,</span>
<span class="p">)</span>

<span class="n">stream_profile</span> <span class="o">=</span> <span class="n">DatastoreProfileKafkaStream</span><span class="p">(</span>
<span class="n">name</span><span class="o">=</span><span class="s2">"kafka-stream-profile"</span><span class="p">,</span>
Expand Down
36 changes: 28 additions & 8 deletions modules/development/agent_deployer/1.0.0/static/source.html
Original file line number Diff line number Diff line change
Expand Up @@ -52,8 +52,17 @@
from mlrun.datastore.datastore_profile import (
DatastoreProfileV3io,
DatastoreProfileKafkaStream,
DatastoreProfileTDEngine,
)

# TimescaleDB support (mlrun >= 1.11), fallback to TDEngine for older versions
try:
from mlrun.datastore.datastore_profile import DatastoreProfilePostgreSQL

_USE_TIMESCALEDB = True
except ImportError:
from mlrun.datastore.datastore_profile import DatastoreProfileTDEngine

_USE_TIMESCALEDB = False
from mlrun.utils import logger


Expand Down Expand Up @@ -117,13 +126,24 @@
)
if mlconf.is_ce_mode():
mlrun_namespace = os.environ.get("MLRUN_NAMESPACE", "mlrun")
tsdb_profile = DatastoreProfileTDEngine(
name="tdengine-tsdb-profile",
user="root",
password="taosdata",
host=f"tdengine-tsdb.{mlrun_namespace}.svc.cluster.local",
port="6041",
)
if _USE_TIMESCALEDB:
tsdb_profile = DatastoreProfilePostgreSQL(
name="timescaledb-tsdb-profile",
user="postgres",
password="postgres",
host=f"timescaledb.{mlrun_namespace}.svc.cluster.local",
port="5432",
database="postgres",
)
else:
# Fallback for older mlrun versions
tsdb_profile = DatastoreProfileTDEngine(
name="tdengine-tsdb-profile",
user="root",
password="taosdata",
host=f"tdengine-tsdb.{mlrun_namespace}.svc.cluster.local",
port="6041",
)

stream_profile = DatastoreProfileKafkaStream(
name="kafka-stream-profile",
Expand Down
36 changes: 28 additions & 8 deletions modules/development/agent_deployer/latest/src/agent_deployer.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,17 @@
from mlrun.datastore.datastore_profile import (
DatastoreProfileV3io,
DatastoreProfileKafkaStream,
DatastoreProfileTDEngine,
)

# TimescaleDB support (mlrun >= 1.11), fallback to TDEngine for older versions
try:
from mlrun.datastore.datastore_profile import DatastoreProfilePostgreSQL

_USE_TIMESCALEDB = True
except ImportError:
from mlrun.datastore.datastore_profile import DatastoreProfileTDEngine

_USE_TIMESCALEDB = False
from mlrun.utils import logger


Expand Down Expand Up @@ -87,13 +96,24 @@ def configure_model_monitoring(self):
)
if mlconf.is_ce_mode():
mlrun_namespace = os.environ.get("MLRUN_NAMESPACE", "mlrun")
tsdb_profile = DatastoreProfileTDEngine(
name="tdengine-tsdb-profile",
user="root",
password="taosdata",
host=f"tdengine-tsdb.{mlrun_namespace}.svc.cluster.local",
port="6041",
)
if _USE_TIMESCALEDB:
tsdb_profile = DatastoreProfilePostgreSQL(
name="timescaledb-tsdb-profile",
user="postgres",
password="postgres",
host=f"timescaledb.{mlrun_namespace}.svc.cluster.local",
port="5432",
database="postgres",
)
else:
# Fallback for older mlrun versions
tsdb_profile = DatastoreProfileTDEngine(
name="tdengine-tsdb-profile",
user="root",
password="taosdata",
host=f"tdengine-tsdb.{mlrun_namespace}.svc.cluster.local",
port="6041",
)

stream_profile = DatastoreProfileKafkaStream(
name="kafka-stream-profile",
Expand Down
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
mlrun==1.10.0-rc41
mlrun==1.10.0
pytest~=8.2
Loading