def take_snapshot()

in gce_rescue/tasks/disks.py [0:0]


def take_snapshot(vm, join_snapshot=None) -> None:
  global snapshot_thread
  if not join_snapshot:
    snapshot_thread = Thread(target=create_snapshot, args=(vm,), daemon=True)
    snapshot_thread.start()
  else:
    snapshot_thread.join()