Fix `create_local_executor` callsite.
@@ -41,7 +41,8 @@ def main(argv):
del argv
tf.compat.v1.enable_v2_behavior()
- service = tff.framework.ExecutorService(tff.framework.create_local_executor())
+ local_executor_factory = tff.framework.create_local_executor()
+ service = tff.framework.ExecutorService(local_executor_factory({}))
server = grpc.server(
concurrent.futures.ThreadPoolExecutor(max_workers=FLAGS.threads))
