Skip to content

Commit

Permalink
fix local backend
Browse files Browse the repository at this point in the history
  • Loading branch information
daniel-goldstein committed Oct 13, 2023
1 parent 8427e0d commit edd8f8a
Showing 1 changed file with 8 additions and 10 deletions.
18 changes: 8 additions & 10 deletions hail/src/main/scala/is/hail/backend/local/LocalBackend.scala
Original file line number Diff line number Diff line change
Expand Up @@ -318,36 +318,34 @@ class LocalBackend(
}
def pyRemoveSequence(name: String) = references(name).removeSequence()

def parse_value_ir(s: String, refMap: java.util.Map[String, String], irMap: java.util.Map[String, BaseIR]): IR = {
def parse_value_ir(s: String, refMap: java.util.Map[String, String]): IR = {
ExecutionTimer.logTime("LocalBackend.parse_value_ir") { timer =>
withExecuteContext(timer) { ctx =>
IRParser.parse_value_ir(s, IRParserEnvironment(ctx, BindingEnv.eval(refMap.asScala.toMap.mapValues(IRParser.parseType).toSeq: _*), irMap.asScala.toMap))
IRParser.parse_value_ir(s, IRParserEnvironment(ctx, BindingEnv.eval(refMap.asScala.toMap.mapValues(IRParser.parseType).toSeq: _*), persistedIR.toMap))
}
}
}

def parse_table_ir(s: String, irMap: java.util.Map[String, BaseIR]): TableIR = {
def parse_table_ir(s: String): TableIR = {
ExecutionTimer.logTime("LocalBackend.parse_table_ir") { timer =>
withExecuteContext(timer) { ctx =>
IRParser.parse_table_ir(s, IRParserEnvironment(ctx, irMap = irMap.asScala.toMap))
IRParser.parse_table_ir(s, IRParserEnvironment(ctx, irMap = persistedIR.toMap))
}
}
}

def parse_matrix_ir(s: String, irMap: java.util.Map[String, BaseIR]): MatrixIR = {
def parse_matrix_ir(s: String): MatrixIR = {
ExecutionTimer.logTime("LocalBackend.parse_matrix_ir") { timer =>
withExecuteContext(timer) { ctx =>
IRParser.parse_matrix_ir(s, IRParserEnvironment(ctx, irMap = irMap.asScala.toMap))
IRParser.parse_matrix_ir(s, IRParserEnvironment(ctx, irMap = persistedIR.toMap))
}
}
}

def parse_blockmatrix_ir(
s: String, irMap: java.util.Map[String, BaseIR]
): BlockMatrixIR = {
def parse_blockmatrix_ir(s: String): BlockMatrixIR = {
ExecutionTimer.logTime("LocalBackend.parse_blockmatrix_ir") { timer =>
withExecuteContext(timer) { ctx =>
IRParser.parse_blockmatrix_ir(s, IRParserEnvironment(ctx, irMap = irMap.asScala.toMap))
IRParser.parse_blockmatrix_ir(s, IRParserEnvironment(ctx, irMap = persistedIR.toMap))
}
}
}
Expand Down

0 comments on commit edd8f8a

Please sign in to comment.