code: def create_datastore_write_config(mapreduce_spec):
    
    force_writes = parse_bool(mapreduce_spec.params.get("force_writes", "false"))
    if force_writes:
      return datastore_rpc.Configuration(force_writes=force_writes)
    else:
      # dev server doesn't support force_writes.
      return datastore_rpc.Configuration()
docs: Creates datastore config to use in write operations.
  
    Args:
      mapreduce_spec: current mapreduce specification as MapreduceSpec.
  
    Returns:
      an instance of datastore_rpc.Configuration to use for all write
      operations in the mapreduce.