initialize

in gems/aws-sdk-databasemigrationservice/lib/aws-sdk-databasemigrationservice/waiters.rb [403:469]

• 66 lines of code
• 1 McCabe index (conditional complexity)

      def initialize(options)
        @client = options.fetch(:client)
        @waiter = Aws::Waiters::Waiter.new({
          max_attempts: 60,
          delay: 15,
          poller: Aws::Waiters::Poller.new(
            operation_name: :describe_replication_tasks,
            acceptors: [
              {
                "argument" => "replication_tasks[].status",
                "expected" => "running",
                "matcher" => "pathAll",
                "state" => "success"
              },
              {
                "argument" => "replication_tasks[].status",
                "expected" => "ready",
                "matcher" => "pathAny",
                "state" => "failure"
              },
              {
                "argument" => "replication_tasks[].status",
                "expected" => "creating",
                "matcher" => "pathAny",
                "state" => "failure"
              },
              {
                "argument" => "replication_tasks[].status",
                "expected" => "stopping",
                "matcher" => "pathAny",
                "state" => "failure"
              },
              {
                "argument" => "replication_tasks[].status",
                "expected" => "stopped",
                "matcher" => "pathAny",
                "state" => "failure"
              },
              {
                "argument" => "replication_tasks[].status",
                "expected" => "failed",
                "matcher" => "pathAny",
                "state" => "failure"
              },
              {
                "argument" => "replication_tasks[].status",
                "expected" => "modifying",
                "matcher" => "pathAny",
                "state" => "failure"
              },
              {
                "argument" => "replication_tasks[].status",
                "expected" => "testing",
                "matcher" => "pathAny",
                "state" => "failure"
              },
              {
                "argument" => "replication_tasks[].status",
                "expected" => "deleting",
                "matcher" => "pathAny",
                "state" => "failure"
              }
            ]
          )
        }.merge(options))
      end