code: def _robust_scan(ds):
      """Attempt to scan data, handling incomplete files."""
      try:
          return ds.scan_data()
      except AssertionError as e:
          if ds.in_last_block():
              wandb.termwarn(
                  f".wandb file is incomplete ({e}), be sure to sync this run again once it's finished"
              )
              return None
          else:
              raise e
  
imports: import fire
  import wandb
  from wandb.proto import wandb_internal_pb2
  from wandb.sdk.internal import datastore
label_desc: Use image node_id 1 for calling a global function with example usage: _robust_scan(ds) and returns: ds, None