def create_collect_driver(train_env, agent, replay_buffer, collect_steps):
    return dynamic_step_driver.DynamicStepDriver(train_env, agent.collect_policy, observers=[replay_buffer.add_batch], num_steps=collect_steps)
def create_collect_driver(train_env, agent, replay_buffer, collect_steps):
    return dynamic_step_driver.DynamicStepDriver(train_env, agent.collect_policy, observers=[replay_buffer.add_batch], num_steps=collect_steps)