-
Notifications
You must be signed in to change notification settings - Fork 344
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[Feat] Support hit rate on ds #244
Conversation
|
CI Test Passed |
CI Test Passed |
CI PY3 Test Passed |
tf.train.replica_device_setter( | ||
worker_device='/job:worker/task:%d' % task_index, cluster=cluster)): | ||
with tf.variable_scope('hitrate_var', reuse=tf.AUTO_REUSE): | ||
var_worker_count = tf.get_variable( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
这些参数的变量是不是放在了各自的 worker 上,没有放在 ps 上
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
是的
outs = sess.run([var_total_hitrate, var_worker_count]) | ||
|
||
# write after all workers have completed the calculation of hitrate. | ||
if outs[1] == worker_count: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
这个结果是只保存了单个 worker 的结果吗
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
outs[0]是全局聚合后最终的hitrate,outs[1]是worker数
CI PY3 Test Passed |
CI PY3 Test Passed |
CI Test Failed |
CI Test Passed |
No description provided.