# Determines how many builds that can be submitted to the builder

      # and be in the build state at a time. Set this to 0 for no restrictions

      ALLOW_CUSTOM_SCMURLS = False

              'type': bool,

              'default': False,

              'desc': 'Is it allowed to directly submit modulemd yaml file?'},

              'type': int,

              'default': 0,

          'net_timeout': {

              'type': int,

              'default': 120,

              raise TypeError("scmurls needs to be a list.")

          self._scmurls = [str(x) for x in l]

          if not isinstance(i, int):

          if i < 0:

      # build whole module in this single continue_batch_build call to keep

      # the number of created buildroots low. The concurrent build limit

      # for mock backend is secured by setting max_workers in

      if conf.system == "mock":

          return False

      import koji  # Placed here to avoid py2/py3 conflicts...

          session.query(models.ComponentBuild).filter_by(

              state=koji.BUILD_STATES['BUILDING']).count():

          return True

      # Get the list of components to be build in this batch. We are not

      # building all `unbuilt_components`, because we can a) meet

      further_work = []

      components_to_build = []

      for c in unbuilt_components:

      # Start build of components in this batch.

      max_workers = 1

      with concurrent.futures.ThreadPoolExecutor(max_workers=max_workers) as executor:

          futures = {executor.submit(start_build_component, builder, c): c for c in components_to_build}

          concurrent.futures.wait(futures)

      @timed(30)

      @patch('module_build_service.auth.get_user', return_value=user)

      @patch('module_build_service.scm.SCM')

             new_callable=PropertyMock, return_value=1)

                                                 mocked_scm, mocked_get_user,

                                                 conf_system, dbg):

          """

          Tests the build of testmodule.yaml using TestModuleBuilder with

          """

          MockedSCM(mocked_scm, 'testmodule', 'testmodule.yaml',

                    '620ec77321b2ea7b0d67d82992dda3e1d67055b4')

          def stop(message):

              """

              Stop the scheduler when the module is built or when we try to build

              """

              main_stop = module_build_service.scheduler.make_simple_stop_condition(db.session)

                  db.session.query(models.ComponentBuild).filter_by(

                  state=koji.BUILD_STATES['BUILDING']).count()

              return main_stop(message) or over_threshold

          # or "ready" state.

          for build in models.ComponentBuild.query.filter_by(module_id=module_build_id).all():

              self.assertEqual(build.state, koji.BUILD_STATES['COMPLETE'])

              # threshold has been met.

              self.assertTrue(build.module_build.state in [models.BUILD_STATES["done"], models.BUILD_STATES["ready"]] )

      @timed(30)

      @patch('module_build_service.auth.get_user', return_value=user)

      @patch('module_build_service.scm.SCM')

             new_callable=PropertyMock, return_value=2)

                                                 mocked_scm, mocked_get_user,

                                                 conf_system, dbg):

          """

          Tests that we try to submit new component build right after

          the previous one finished without waiting for all

          """

          MockedSCM(mocked_scm, 'testmodule-more-components', 'testmodule-more-components.yaml',

                    '620ec77321b2ea7b0d67d82992dda3e1d67055b4')

          def stop(message):

              """

              Stop the scheduler when the module is built or when we try to build

              """

              main_stop = module_build_service.scheduler.make_simple_stop_condition(db.session)

              num_building = db.session.query(models.ComponentBuild).filter_by(

                  state=koji.BUILD_STATES['BUILDING']).count()

              TestBuild._global_var.append(num_building)

              return main_stop(message) or over_threshold

          # when we should be building just single component:

          #   1) module-base-macros in first batch.

          #   2) The last component of second batch.

          # does not work correctly.

          num_builds = [k for k, g in itertools.groupby(TestBuild._global_var)]

          self.assertEqual(num_builds.count(1), 2)

      @timed(30)

      @patch('module_build_service.auth.get_user', return_value=user)

      @patch('module_build_service.scm.SCM')

             new_callable=PropertyMock, return_value=1)

                                    mocked_get_user, conf_system, dbg):

          """

          Tests that if the build in batch fails, other components in a batch

      @timed(30)

      @patch('module_build_service.auth.get_user', return_value=user)

      @patch('module_build_service.scm.SCM')

             new_callable=PropertyMock, return_value=1)

                                    mocked_get_user, conf_system, dbg):

          """

          Tests that if the build in batch fails, other components in a batch