Permalink
Browse files

actually, pretty much everywhere we shouldn't be overriding the state…

…, just merging it
  • Loading branch information...
1 parent 3bfbaab commit 03b2a7e783672c5b7f4b8baa39ef1ce7827b60ef Dhruv Bansal committed Feb 21, 2014
@@ -8,7 +8,7 @@ module FTPSyncerOverride
# Saves the syncer as a stash in Vayacondios.
def before_sync
super()
- Wukong::Deploy.vayacondios_client.set!(vayacondios_topic, 'ftp', self)
+ Wukong::Deploy.vayacondios_client.set(vayacondios_topic, 'ftp', self)
end
# Announces a successful sync and updates the last sync state
@@ -37,7 +37,7 @@ def on_error error
message: error.message,
files: self.files,
})
- Wukong::Deploy.vayacondios_client.set!(vayacondios_topic, "ftp.last", { state: 0, time: Time.now.utc.to_i })
+ Wukong::Deploy.vayacondios_client.set(vayacondios_topic, "ftp.last", { state: 0, time: Time.now.utc.to_i })
end
# Returns the Vayacondios topic for this FTP syncer.
@@ -8,7 +8,7 @@ module PrepareSyncerOverride
# Saves the syncer as a stash in Vayacondios.
def before_sync
super()
- Wukong::Deploy.vayacondios_client.set!(vayacondios_topic, 'prepare', self)
+ Wukong::Deploy.vayacondios_client.set(vayacondios_topic, 'prepare', self)
end
# Announces a successful sync and updates the last sync state
@@ -21,7 +21,7 @@ def after_sync
counts: counts,
files: files,
}.tap { |e| e[:duration] = duration if duration })
- Wukong::Deploy.vayacondios_client.set!(vayacondios_topic, "prepare.last", { state: (success? ? 1 : 0), time: Time.now.utc.to_i })
+ Wukong::Deploy.vayacondios_client.set(vayacondios_topic, "prepare.last", { state: (success? ? 1 : 0), time: Time.now.utc.to_i })
end
# Announces an error during a sync and updates the last sync
@@ -36,7 +36,7 @@ def on_error error
counts: counts,
files: files,
})
- Wukong::Deploy.vayacondios_client.set!(vayacondios_topic, "prepare.last", { state: 0, time: Time.now.utc.to_i })
+ Wukong::Deploy.vayacondios_client.set(vayacondios_topic, "prepare.last", { state: 0, time: Time.now.utc.to_i })
end
# Returns the Vayacondios topic for this PrepareSyncer.
@@ -8,7 +8,7 @@ module S3SyncerOverride
# Saves the syncer as a stash in Vayacondios.
def before_sync
super()
- Wukong::Deploy.vayacondios_client.set!(vayacondios_topic, 's3', self)
+ Wukong::Deploy.vayacondios_client.set(vayacondios_topic, 's3', self)
end
# Announces a successful sync and updates the last sync state
@@ -20,7 +20,7 @@ def after_sync
step: 's3',
bytes: (bytes || 0),
}.tap { |e| e[:duration] = duration if duration })
- Wukong::Deploy.vayacondios_client.set!(vayacondios_topic, "s3.last", { state: 1, time: Time.now.utc.to_i })
+ Wukong::Deploy.vayacondios_client.set(vayacondios_topic, "s3.last", { state: 1, time: Time.now.utc.to_i })
end
# Announces an error during a sync and updates the last sync
@@ -34,7 +34,7 @@ def on_error error
message: error.message,
bytes: bytes,
})
- Wukong::Deploy.vayacondios_client.set!(vayacondios_topic, "s3.last", { state: 0, time: Time.now.utc.to_i })
+ Wukong::Deploy.vayacondios_client.set(vayacondios_topic, "s3.last", { state: 0, time: Time.now.utc.to_i })
end
# Returns the Vayacondios topic for this S3Syncer.

0 comments on commit 03b2a7e

Please sign in to comment.