Skip to content
New issue

Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.

#

By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? # to your account

Added STR_TO_MILLIS func to all order by ts queries #72

Merged
merged 2 commits into from
Feb 10, 2025
Merged

Added STR_TO_MILLIS func to all order by ts queries #72

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
40275ad
Added STR_TO_MILLIS func to all order by ts queries
TJ202 Feb 10, 2025
d027235
God knows why some src files in controlflow showed up - removing it
TJ202 Feb 10, 2025
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
2 changes: 1 addition & 1 deletion libs/agentc_cli/agentc_cli/cmds/status.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ def db_catalog_status(kind, bucket, cluster, compare):
GROUP BY b.catalog_identifier
) AS subquery
ON a.version.identifier = subquery.catalog_identifier
ORDER BY a.version.timestamp DESC LIMIT 1;
ORDER BY STR_TO_MILLIS(a.version.timestamp) DESC LIMIT 1;
"""
else:
# Query to get the metadata based on the kind of catalog
Expand Down
6 changes: 3 additions & 3 deletions libs/agentc_core/agentc_core/analytics/ddls/all_sessions.sqlpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ WITH
PARTITION BY
_id
ORDER BY
rsli.timestamp ASC
STR_TO_MILLIS(rsli.timestamp) ASC
) AS rn
)
FROM
Expand All @@ -39,7 +39,7 @@ LETTING
SELECT VALUE
gii
ORDER BY
gii.rsl.timestamp ASC
STR_TO_MILLIS(gii.rsl.timestamp) ASC
) AS gi
SELECT
gi.rsl.content AS content,
Expand All @@ -59,7 +59,7 @@ SELECT
SELECT VALUE
gi.rsl.timestamp
ORDER BY
gi.rsl.timestamp ASC
STR_TO_MILLIS(gi.rsl.timestamp) ASC
LIMIT 1
)[0] AS start_t,
vid,
Expand Down
4 changes: 2 additions & 2 deletions libs/agentc_core/agentc_core/analytics/ddls/exchanges.sqlpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ WITH LatestGenerations AS (
msgsi.content,
msgsi.row_num
ORDER BY
msgsi.timestamp ASC
STR_TO_MILLIS(msgsi.timestamp) ASC
LIMIT 1
)[0],
last_message = (
Expand All @@ -40,7 +40,7 @@ WITH LatestGenerations AS (
COALESCE(msgsi.content, msgsi.tool_calls) AS content,
msgsi.row_num
ORDER BY
msgsi.timestamp DESC
STR_TO_MILLIS(msgsi.timestamp) DESC
LIMIT 1
)[0],
context = (
Expand Down
2 changes: 1 addition & 1 deletion libs/agentc_core/agentc_core/analytics/ddls/last_session.sqlpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ CREATE OR REPLACE ANALYTICS FUNCTION
SELECT VALUE
s.sid
ORDER BY
s.start_t DESC
STR_TO_MILLIS(s.start_t) DESC
LIMIT 1
)[0]
};
2 changes: 1 addition & 1 deletion libs/agentc_core/agentc_core/analytics/ddls/tool_calls.sqlpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,5 +32,5 @@ SELECT
s1.vid AS vid,
tool_calls AS tool_calls
ORDER BY
vid.timestamp DESC
STR_TO_MILLIS(vid.timestamp) DESC
;
2 changes: 1 addition & 1 deletion libs/agentc_core/agentc_core/analytics/ddls/trajectories.sqlpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ LETTING
SELECT VALUE
gi.msg
ORDER BY
gi.msg.timestamp ASC
STR_TO_MILLIS(gi.msg.timestamp) ASC
)
SELECT
s.sid AS sid,
Expand Down
2 changes: 1 addition & 1 deletion libs/agentc_core/agentc_core/catalog/catalog/db.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -237,7 +237,7 @@ def version(self) -> VersionDescriptor:
ts_query = f"""
FROM `{self.bucket}`.`{DEFAULT_CATALOG_SCOPE}`.`{self.kind}{DEFAULT_META_COLLECTION_NAME}` AS t
SELECT VALUE t.version
ORDER BY t.version.timestamp DESC
ORDER BY STR_TO_MILLIS(t.version.timestamp) DESC
LIMIT 1
"""
res, err = execute_query(self.cluster, ts_query)
Expand Down
2 changes: 1 addition & 1 deletion libs/agentc_core/agentc_core/learned/embedding.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ def validate_embedding_model(self) -> "EmbeddingModel":
SELECT
VALUE mc.embedding_model
ORDER BY
mc.version.timestamp DESC
STR_TO_MILLIS(mc.version.timestamp) DESC
LIMIT 1
"""
]
Expand Down
4 changes: 2 additions & 2 deletions templates/agents/with_controlflow/notebook.ipynb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@
" msgsi.content,\n",
" msgsi.row_num\n",
" ORDER BY\n",
" msgsi.timestamp ASC\n",
" STR_TO_MILLIS(msgsi.timestamp) ASC\n",
" LIMIT 1\n",
" )[0],\n",
" last_message = (\n",
Expand All @@ -106,7 +106,7 @@
" COALESCE(msgsi.content, msgsi.tool_calls) AS content,\n",
" msgsi.row_num\n",
" ORDER BY \n",
" msgsi.timestamp DESC\n",
" STR_TO_MILLIS(msgsi.timestamp) DESC\n",
" LIMIT 1\n",
" )[0],\n",
" context = (\n",
Expand Down