diff --git a/lambda/replicate-snapshots/replicator.py b/lambda/replicate-snapshots/replicator.py
index 74d5d79..a0ea9fe 100644
--- a/lambda/replicate-snapshots/replicator.py
+++ b/lambda/replicate-snapshots/replicator.py
@@ -33,7 +33,9 @@ def __init__(self):
     self.ec2_dest = boto3.resource('ec2', region_name=self.AWS_DEST_REGION)
 
   def get_source_snapshots(self):
-    filters = [{'Name':'tag-key', 'Values': [self.REPLICATE_TAG]}]
+    filters = [
+      {'Name':'tag-key', 'Values': [self.REPLICATE_TAG]},
+      {'Name': 'status', 'Values': ['completed']}]
     snapshots = self.ec2_source.snapshots.filter(Filters=filters)
     return snapshots