Fix tick in multi node parallel (#2042) (#2047)
* check in fixes * fix by adding boxing method * register tick op * move code and add more check * fix typo * fix bug when filtering op nodes before adding tick
Showing
- oneflow/core/graph/boxing_task_node.cpp 8 additions, 0 deletionsoneflow/core/graph/boxing_task_node.cpp
- oneflow/core/graph/boxing_task_node.h 1 addition, 0 deletionsoneflow/core/graph/boxing_task_node.h
- oneflow/core/graph/logical_node.cpp 19 additions, 5 deletionsoneflow/core/graph/logical_node.cpp
- oneflow/core/job_completer/autotick.cpp 62 additions, 28 deletionsoneflow/core/job_completer/autotick.cpp
- oneflow/core/job_completer/job_completer.cpp 0 additions, 28 deletionsoneflow/core/job_completer/job_completer.cpp
- oneflow/core/kernel/partial_tick_kernel.cpp 7 additions, 0 deletionsoneflow/core/kernel/partial_tick_kernel.cpp
- oneflow/core/kernel/partial_tick_kernel.h 23 additions, 0 deletionsoneflow/core/kernel/partial_tick_kernel.h
- oneflow/core/operator/op_conf.proto 6 additions, 0 deletionsoneflow/core/operator/op_conf.proto
- oneflow/core/operator/operator.h 6 additions, 0 deletionsoneflow/core/operator/operator.h
- oneflow/core/operator/partial_tick_op.cpp 35 additions, 0 deletionsoneflow/core/operator/partial_tick_op.cpp
- oneflow/core/operator/partial_tick_op.h 30 additions, 0 deletionsoneflow/core/operator/partial_tick_op.h
- oneflow/core/operator/sink_tick_op.cpp 1 addition, 0 deletionsoneflow/core/operator/sink_tick_op.cpp
- oneflow/core/operator/source_tick_op.cpp 1 addition, 0 deletionsoneflow/core/operator/source_tick_op.cpp
- oneflow/core/operator/tick_op.cpp 1 addition, 0 deletionsoneflow/core/operator/tick_op.cpp
Please register or sign in to comment