     .option '-h, --hosts <hosts>', 'A comma separated list of cassandra hosts', parseCassandraHosts
     .option '-k, --keyspace <keyspace>', 'Cassandra keyspace used for migration and schema_version table'
     .option '-q, --quiet', 'Silence non-error output (default is false)'
+    .option '-i, --interval <interval>', 'Milliseconds to wait between migration queries are executed'
     .option '-t, --target-version <version>', 'Maximum migration version to apply (default runs all migrations)'
     .parse(process.argv)
 


    migrationFunctions = _(migrations)
    .map ([file, version]) ->
      -> applyMigration config, client, keyspace, file, version
    .value()

    migrationFunctions.reduce(Q.when, Q(schemaVersion))

      cassandraClient = client
      getSchemaVersion config, client, keyspace
      .then (schemaVersion) ->
        migrate config, client, keyspace, migrationFiles, schemaVersion, interval
      .then (version) ->
        code = 0
      .catch (error) ->
