Skip to content

Commit

Permalink
clickhouse add to launcher solution list
Browse files Browse the repository at this point in the history
  • Loading branch information
jangorecki committed Mar 7, 2019
1 parent 4b37e5e commit eade630
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
2 changes: 1 addition & 1 deletion helpers.R
Original file line number Diff line number Diff line change
Expand Up @@ -192,7 +192,7 @@ upgraded.solution = function(x, validate=TRUE) {
git = if (!file.exists(f)) NA_character_ else toString(readLines(f, warn=FALSE))
if (!nzchar(git)) git = NA_character_
ans = list(version=version, git=git)
if (validate && (is.na(ans[["version"]]) || !nzchar(ans[["version"]]))) # for some reasom it happened that one pandas run has empty char version, raise early such cases
if (validate && (is.na(ans[["version"]]) || !nzchar(ans[["version"]]))) # for some reason it happened that one pandas run has empty char version, raise early such cases
stop(sprintf("version of %s could not be determined based on %s/VERSION file, investigate and fix logs.csv if needed", x, ns))
ans
}
Expand Down
4 changes: 3 additions & 1 deletion launcher.R
Original file line number Diff line number Diff line change
Expand Up @@ -43,9 +43,11 @@ solution = rbindlist(list(
modin = list(task=c("sort")),
pandas = list(task=c("groupby","join","sort")),
pydatatable = list(task=c("groupby","join","sort")),
spark = list(task=c("groupby","join","sort"))
spark = list(task=c("groupby","join","sort")),
clickhouse = list(task=c("groupby"))
), idcol="solution")
solution = solution[run_solutions, on="solution", nomatch=NULL] # filter for env var RUN_SOLUTIONS
stopifnot(nrow(solution) > 0L) # when added new solution and forget to add here this will catch

# what to run
dt = solution[data, on="task", allow.cartesian=TRUE]
Expand Down

0 comments on commit eade630

Please sign in to comment.