     Logger.debug("Retrieving unit #{unit_name} on cluster #{etcd_token}...")
     api = get_fleet_api(etcd_token)
     unit = case FleetApi.Etcd.get_unit(api, unit_name) do
-      {:ok, unit} -> unit
+      {:ok, unit}      -> unit
       {:error, reason} ->
         Logger.error("Failed to retrieve unit #{unit_name} on cluster #{etcd_token}:  #{inspect reason}")
         nil


  @type t :: %__MODULE__{}

  defstruct name: nil,
            options: nil,
            etcd_token: nil,
            dst_port: nil,
            desiredState: nil,
            currentState: nil,
            machineID: nil,
            systemdLoadState: nil,
            systemdActiveState: nil,
            systemdSubState: nil

  @spec get_fleet_api(String.t) :: pid
  def get_fleet_api(etcd_token) do

  def is_launched?(unit) do
    case unit.currentState do
      "launched" -> true
      _          -> {false, unit.currentState}
    end
  end

