Skip to content

adding module on_start to improve how poll callbacks are loaded

Sign in for the full log view
GitHub Actions / Test Results failed May 24, 2024 in 0s

1 fail, 8 skipped, 235 pass in 16s

244 tests   235 ✅  16s ⏱️
  1 suites    8 💤
  1 files      1 ❌

Results for commit 3920fca.

Annotations

Check warning on line 0 in sarracenia.flowcb.accept.testretry_test

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_after_accept (sarracenia.flowcb.accept.testretry_test) failed

tests/junit/test-results.xml [took 0s]
Raw output
KeyError: 'https://TestUsername:TestPassword@options.sendTo.url/Path/File.txt'
caplog = <_pytest.logging.LogCaptureFixture object at 0x7fd87129e2f0>
mocker = <pytest_mock.plugin.MockerFixture object at 0x7fd87129ee60>

    @pytest.mark.depends(on=['test___init__'])
    def test_after_accept(caplog, mocker):
        #Set 1 - When random is True, with a message having isRetry
        caplog.clear()
        options = sarracenia.config.default_config()
        options.sendTo = 'http://options.sendTo.url'
        options.logLevel = 'DEBUG'
        worklist = make_worklist()
        worklist.incoming = [make_message()]
        mocker.patch('random.randint', return_value=0)
        testretry = TestRetry(options)
        testretry.after_accept(worklist)
        assert len(worklist.incoming) == 0
        assert "return from testretry after_accept" in caplog.messages
    
    
        #Set 2 - When random is True, with a message having isRetry
        caplog.clear()
        options = sarracenia.config.default_config()
        options.sendTo = 'http://options.sendTo.url'
        options.logLevel = 'DEBUG'
        testretry = TestRetry(options)
        testretry.sendTo = 'http://testretry.sendTo.url'
        testretry.msg_baseUrl_good = 'http://testretry.msg_baseUrl_good.url'
        message_isRetry = make_message(isRetry=True)
        worklist = make_worklist()
        worklist.incoming = [message_isRetry]
        testretry.after_accept(worklist)
        assert len(worklist.incoming) == 0
        assert options.sendTo == 'http://testretry.sendTo.url'
        assert options.details.url.netloc == 'testretry.sendTo.url'
    
    
        #Set 3 - When random is False, there's nothing that gets retried
        caplog.clear()
        options = sarracenia.config.default_config()
        options.sendTo = 'https://TestUsername:TestPassword@options.sendTo.url/Path/File.txt'
        options.component = 'watch'
        options.logLevel = 'DEBUG'
        testretry = TestRetry(options)
        message = make_message()
        worklist = make_worklist()
        worklist.incoming = [message]
        mocker.patch('random.randint', return_value=1)
>       testretry.after_accept(worklist)

tests/sarracenia/flowcb/accept/testretry_test.py:87: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
sarracenia/flowcb/accept/testretry.py:56: in after_accept
    ok, self.o.details = self.o.credentials.get(self.sendTo)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <sarracenia.credentials.CredentialDB object at 0x7fd884aaf250>
urlstr = 'https://TestUsername:TestPassword@options.sendTo.url/Path/File.txt'

    def get(self, urlstr):
        """Retrieve a Credential from the DB by urlstr. If the Credential is valid, but not already cached, it will be
        added to the CredentialDB.
    
        Args:
            urlstr (str): credentials as URL string to be parsed.
    
        Returns:
            tuple: containing
                cache_result (bool): ``True`` if the credential was retrieved from the CredentialDB cache, ``False``
                    if it was not in the cache. Note that ``False`` does not imply the Credential or urlstr is
                    invalid.
                credential (sarracenia.credentials.Credential): the Credential
                    object matching the urlstr, ``None`` if urlstr is invalid.
        """
        #logger.debug("CredentialDB get %s" % urlstr)
    
        # already cached
    
        if self.has(urlstr):
            #logger.debug("CredentialDB get in cache %s %s" % (urlstr,self.credentials[urlstr]))
            return True, self.credentials[urlstr]
    
        # create url object if needed
    
        url = urllib.parse.urlparse(urlstr)
    
        # add anonymous default, if necessary.
        if ( 'amqp' in url.scheme ) and \
           ( (url.username == None) or (url.username == '') ):
            urlstr = urllib.parse.urlunparse( ( url.scheme, \
                'anonymous:anonymous@%s' % url.netloc, url.path, None, None, url.port ) )
            url = urllib.parse.urlparse(urlstr)
            if self.isValid(url):
                self.add(urlstr)
                return False, self.credentials[urlstr.replace(':anonymous@','@')]
    
        # resolved from defined credentials
        ok, details = self._resolve(urlstr, url)
        if ok: return True, details
    
        # not found... is it valid ?
        if not self.isValid(url):
            return False, None
    
        # cache it as is... we dont want to validate every time
    
        self.add(urlstr)
>       return False, self.credentials[urlstr]
E       KeyError: 'https://TestUsername:TestPassword@options.sendTo.url/Path/File.txt'

sarracenia/credentials.py:236: KeyError

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

8 skipped tests found

There are 8 skipped tests, see "Raw output" for the full list of skipped tests.
Raw output
sarracenia.flowcb.retry_test ‑ test_cleanup
sarracenia.transfer.azure_test ‑ test_connect
sarracenia.transfer.azure_test ‑ test_delete
sarracenia.transfer.azure_test ‑ test_get
sarracenia.transfer.azure_test ‑ test_ls
sarracenia.transfer.azure_test ‑ test_put
sarracenia.transfer.azure_test ‑ test_rename
sarracenia.transfer.azure_test ‑ test_rmdir

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

244 tests found

There are 244 tests, see "Raw output" for the full list of tests.
Raw output
sarracenia.__init___test ‑ test_baseUrlParse
sarracenia.__init___test ‑ test_durationToSeconds
sarracenia.__init___test ‑ test_durationToString
sarracenia.__init___test ‑ test_nowflt
sarracenia.__init___test ‑ test_nowstr
sarracenia.__init___test ‑ test_timeValidate
sarracenia.__init___test ‑ test_timeflt2str
sarracenia.__init___test ‑ test_timestr2flt
sarracenia.__init___test ‑ test_timev2tov3str
sarracenia.__init___test.Test_Message ‑ test_computeIdentity
sarracenia.__init___test.Test_Message ‑ test_copyDict
sarracenia.__init___test.Test_Message ‑ test_dumps
sarracenia.__init___test.Test_Message ‑ test_fromFileData
sarracenia.__init___test.Test_Message ‑ test_fromFileInfo
sarracenia.__init___test.Test_Message ‑ test_fromStream
sarracenia.__init___test.Test_Message ‑ test_getContent
sarracenia.__init___test.Test_Message ‑ test_setReport
sarracenia.__init___test.Test_Message ‑ test_updatePaths
sarracenia.__init___test.Test_Message ‑ test_validate
sarracenia.config_test ‑ test_broker_finalize
sarracenia.config_test ‑ test_read_line_add_option
sarracenia.config_test ‑ test_read_line_counts
sarracenia.config_test ‑ test_read_line_declare
sarracenia.config_test ‑ test_read_line_duration
sarracenia.config_test ‑ test_read_line_flags
sarracenia.config_test ‑ test_read_line_perms
sarracenia.config_test ‑ test_read_line_sets
sarracenia.config_test ‑ test_source_from_exchange
sarracenia.config_test ‑ test_variableExpansion
sarracenia.diskqueue_test ‑ test___len__
sarracenia.diskqueue_test ‑ test__is_exired__TooLate
sarracenia.diskqueue_test ‑ test__is_exired__TooSoon
sarracenia.diskqueue_test ‑ test_cleanup
sarracenia.diskqueue_test ‑ test_get__Multi
sarracenia.diskqueue_test ‑ test_get__Single
sarracenia.diskqueue_test ‑ test_in_cache
sarracenia.diskqueue_test ‑ test_msgFromJSON
sarracenia.diskqueue_test ‑ test_msgToJSON
sarracenia.diskqueue_test ‑ test_msg_get_from_file
sarracenia.diskqueue_test ‑ test_msg_get_from_file__NoLine
sarracenia.diskqueue_test ‑ test_needs_requeuing
sarracenia.diskqueue_test ‑ test_on_housekeeping
sarracenia.diskqueue_test ‑ test_on_housekeeping__FinishRetry
sarracenia.diskqueue_test ‑ test_put__Multi
sarracenia.diskqueue_test ‑ test_put__Single
sarracenia.flowcb.accept.dateappend_test ‑ test_after_accept
sarracenia.flowcb.accept.delete__accept_test ‑ test___init__
sarracenia.flowcb.accept.delete__accept_test ‑ test_after_accept
sarracenia.flowcb.accept.downloadbaseurl_test ‑ test___init__
sarracenia.flowcb.accept.downloadbaseurl_test ‑ test_after_accept
sarracenia.flowcb.accept.hourtree_test ‑ test_after_accept
sarracenia.flowcb.accept.httptohttps_test ‑ test_after_accept
sarracenia.flowcb.accept.longflow_test ‑ test_after_accept
sarracenia.flowcb.accept.pathreplace_test ‑ test___init__
sarracenia.flowcb.accept.pathreplace_test ‑ test_after_accept
sarracenia.flowcb.accept.pathreplace_test ‑ test_on_start
sarracenia.flowcb.accept.posthourtree_test ‑ test_after_accept
sarracenia.flowcb.accept.postoverride_test ‑ test___init__
sarracenia.flowcb.accept.postoverride_test ‑ test_after_accept
sarracenia.flowcb.accept.printlag_test ‑ test_after_accept
sarracenia.flowcb.accept.rename4jicc_test ‑ test___init__
sarracenia.flowcb.accept.rename4jicc_test ‑ test_after_accept
sarracenia.flowcb.accept.renamedmf_test ‑ test___init__
sarracenia.flowcb.accept.renamedmf_test ‑ test_after_accept
sarracenia.flowcb.accept.renamewhatfn_test ‑ test___init__
sarracenia.flowcb.accept.renamewhatfn_test ‑ test_after_accept
sarracenia.flowcb.accept.save_test ‑ test___init__
sarracenia.flowcb.accept.save_test ‑ test_after_accept
sarracenia.flowcb.accept.speedo_test ‑ test___init__
sarracenia.flowcb.accept.speedo_test ‑ test_after_accept
sarracenia.flowcb.accept.sundowpxroute_test ‑ test___init__
sarracenia.flowcb.accept.sundowpxroute_test ‑ test_after_accept
sarracenia.flowcb.accept.testretry_test ‑ test___init__
sarracenia.flowcb.accept.testretry_test ‑ test_after_accept
sarracenia.flowcb.accept.toclusters_test ‑ test___init__
sarracenia.flowcb.accept.toclusters_test ‑ test_after_accept
sarracenia.flowcb.accept.tohttp_test ‑ test___init__
sarracenia.flowcb.accept.tohttp_test ‑ test_after_accept
sarracenia.flowcb.accept.tolocal_test ‑ test___init__
sarracenia.flowcb.accept.tolocal_test ‑ test_after_accept
sarracenia.flowcb.accept.tolocalfile_test ‑ test___init__
sarracenia.flowcb.accept.tolocalfile_test ‑ test_after_accept
sarracenia.flowcb.accept.trim_legacy_fields_test ‑ test_after_accept
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[D_-.grib]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[E_-.bin]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[G_-.grid]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[H_-.grib]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[IX-.hdf]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[I_-.bufr]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[K_-.crex]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[LT-.iwxxm]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[L_-.grib]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[O_-.grib]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[P_-.bin]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[Q_-.bin]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[R_-.bin]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[XW-.txt]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[X_-.cap]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[Y_-.grib]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test___find_type[__-.txt]
sarracenia.flowcb.accept.wmotypesuffix_test ‑ test_after_accept
sarracenia.flowcb.filter.wmo00_test ‑ test___init__
sarracenia.flowcb.filter.wmo00_test ‑ test_after_accept
sarracenia.flowcb.filter.wmo00_test ‑ test_open_accumulated_file
sarracenia.flowcb.gather.am__gather_test ‑ test_SM_bulletin
sarracenia.flowcb.gather.am__gather_test ‑ test_am_binary_bulletin
sarracenia.flowcb.gather.am__gather_test ‑ test_bulletin_double_linesep
sarracenia.flowcb.gather.am__gather_test ‑ test_bulletin_header_five_fileds
sarracenia.flowcb.gather.am__gather_test ‑ test_bulletin_header_six_fileds
sarracenia.flowcb.gather.am__gather_test ‑ test_bulletin_header_trailing_space
sarracenia.flowcb.gather.am__gather_test ‑ test_bulletin_invalid_timestamp
sarracenia.flowcb.gather.am__gather_test ‑ test_bulletin_timestamp_6chars_plus
sarracenia.flowcb.gather.am__gather_test ‑ test_bulletin_wrong_station
sarracenia.flowcb.gather.am__gather_test ‑ test_cacn_erronous
sarracenia.flowcb.gather.am__gather_test ‑ test_cacn_regular
sarracenia.flowcb.gather.am_test ‑ test_SM_bulletin
sarracenia.flowcb.gather.am_test ‑ test_am_binary_bulletin
sarracenia.flowcb.gather.am_test ‑ test_bulletin_double_linesep
sarracenia.flowcb.gather.am_test ‑ test_bulletin_header_five_fileds
sarracenia.flowcb.gather.am_test ‑ test_bulletin_header_six_fileds
sarracenia.flowcb.gather.am_test ‑ test_bulletin_header_trailing_space
sarracenia.flowcb.gather.am_test ‑ test_bulletin_invalid_timestamp
sarracenia.flowcb.gather.am_test ‑ test_bulletin_timestamp_6chars_plus
sarracenia.flowcb.gather.am_test ‑ test_bulletin_wrong_station
sarracenia.flowcb.gather.am_test ‑ test_cacn_erronous
sarracenia.flowcb.gather.am_test ‑ test_cacn_regular
sarracenia.flowcb.nodupe.__nodupe___test ‑ test_after_accept
sarracenia.flowcb.nodupe.__nodupe___test ‑ test_after_accept__InFlight
sarracenia.flowcb.nodupe.__nodupe___test ‑ test_after_accept__WithFileAges
sarracenia.flowcb.nodupe.__nodupe___test ‑ test_on_housekeeping
sarracenia.flowcb.nodupe.__nodupe___test ‑ test_restart
sarracenia.flowcb.nodupe.data_test ‑ test_after_accept
sarracenia.flowcb.nodupe.disk_test ‑ test__not_in_cache
sarracenia.flowcb.nodupe.disk_test ‑ test_after_accept
sarracenia.flowcb.nodupe.disk_test ‑ test_after_accept__InFlight
sarracenia.flowcb.nodupe.disk_test ‑ test_after_accept__WithFileAges
sarracenia.flowcb.nodupe.disk_test ‑ test_check_message
sarracenia.flowcb.nodupe.disk_test ‑ test_clean
sarracenia.flowcb.nodupe.disk_test ‑ test_clean__Persist_DelPath
sarracenia.flowcb.nodupe.disk_test ‑ test_close
sarracenia.flowcb.nodupe.disk_test ‑ test_close__ErrorThrown
sarracenia.flowcb.nodupe.disk_test ‑ test_close__Unlink
sarracenia.flowcb.nodupe.disk_test ‑ test_close__Unlink_ErrorThrown
sarracenia.flowcb.nodupe.disk_test ‑ test_deriveKey
sarracenia.flowcb.nodupe.disk_test ‑ test_on_housekeeping
sarracenia.flowcb.nodupe.disk_test ‑ test_on_start
sarracenia.flowcb.nodupe.disk_test ‑ test_on_stop
sarracenia.flowcb.nodupe.disk_test ‑ test_open__WithData
sarracenia.flowcb.nodupe.disk_test ‑ test_open__WithFile
sarracenia.flowcb.nodupe.disk_test ‑ test_open__WithoutFile
sarracenia.flowcb.nodupe.disk_test ‑ test_save
sarracenia.flowcb.nodupe.disk_test ‑ test_save__Open_Error
sarracenia.flowcb.nodupe.disk_test ‑ test_save__Unlink_Error
sarracenia.flowcb.nodupe.name_test ‑ test_after_accept
sarracenia.flowcb.nodupe.redis_test ‑ test__deriveKey
sarracenia.flowcb.nodupe.redis_test ‑ test__is_new
sarracenia.flowcb.nodupe.redis_test ‑ test_after_accept
sarracenia.flowcb.nodupe.redis_test ‑ test_after_accept__InFlight
sarracenia.flowcb.nodupe.redis_test ‑ test_after_accept__WithFileAges
sarracenia.flowcb.nodupe.redis_test ‑ test_on_housekeeping
sarracenia.flowcb.nodupe.redis_test ‑ test_on_start
sarracenia.flowcb.nodupe.redis_test ‑ test_on_stop
sarracenia.flowcb.retry_test ‑ test_after_accept
sarracenia.flowcb.retry_test ‑ test_after_accept__SmallQty
sarracenia.flowcb.retry_test ‑ test_after_post
sarracenia.flowcb.retry_test ‑ test_after_work
sarracenia.flowcb.retry_test ‑ test_after_work__SmallQty
sarracenia.flowcb.retry_test ‑ test_after_work__WLFailed
sarracenia.flowcb.retry_test ‑ test_cleanup
sarracenia.flowcb.retry_test ‑ test_metricsReport
sarracenia.flowcb.retry_test ‑ test_on_housekeeping
sarracenia.identity.__identity___test ‑ test___Property_value
sarracenia.identity.__identity___test ‑ test_factory
sarracenia.identity.__identity___test ‑ test_get_method
sarracenia.identity.__identity___test ‑ test_update_file
sarracenia.identity.arbitrary_test ‑ test___Property_value
sarracenia.identity.arbitrary_test ‑ test___init__
sarracenia.identity.arbitrary_test ‑ test_registered_as
sarracenia.identity.arbitrary_test ‑ test_set_path
sarracenia.identity.arbitrary_test ‑ test_update
sarracenia.identity.md5_test ‑ test_registered_as
sarracenia.identity.md5_test ‑ test_set_path
sarracenia.identity.md5_test ‑ test_update
sarracenia.identity.random_test ‑ test___Property_value
sarracenia.identity.random_test ‑ test_registered_as
sarracenia.identity.random_test ‑ test_set_path
sarracenia.identity.sha512_test ‑ test_registered_as
sarracenia.identity.sha512_test ‑ test_set_path
sarracenia.identity.sha512_test ‑ test_update
sarracenia.redisqueue_test ‑ test___len__
sarracenia.redisqueue_test ‑ test__in_cache
sarracenia.redisqueue_test ‑ test__is_exired__TooLate
sarracenia.redisqueue_test ‑ test__is_exired__TooSoon
sarracenia.redisqueue_test ‑ test__lpop
sarracenia.redisqueue_test ‑ test__msgFromJSON
sarracenia.redisqueue_test ‑ test__msgToJSON
sarracenia.redisqueue_test ‑ test__needs_requeuing
sarracenia.redisqueue_test ‑ test_cleanup
sarracenia.redisqueue_test ‑ test_get__Locked
sarracenia.redisqueue_test ‑ test_get__NotLocked_Multi
sarracenia.redisqueue_test ‑ test_get__NotLocked_Single
sarracenia.redisqueue_test ‑ test_on_housekeeping
sarracenia.redisqueue_test ‑ test_on_housekeeping__FinishRetry
sarracenia.redisqueue_test ‑ test_on_housekeeping__TooSoon
sarracenia.redisqueue_test ‑ test_put__Multi
sarracenia.redisqueue_test ‑ test_put__Single
sarracenia.transfer.__transfer___test ‑ test___init__
sarracenia.transfer.__transfer___test ‑ test_factory
sarracenia.transfer.azure_test ‑ test___credentials
sarracenia.transfer.azure_test ‑ test___init__
sarracenia.transfer.azure_test ‑ test_cd
sarracenia.transfer.azure_test ‑ test_cd_forced
sarracenia.transfer.azure_test ‑ test_check_is_connected
sarracenia.transfer.azure_test ‑ test_chmod
sarracenia.transfer.azure_test ‑ test_close
sarracenia.transfer.azure_test ‑ test_connect
sarracenia.transfer.azure_test ‑ test_delete
sarracenia.transfer.azure_test ‑ test_get
sarracenia.transfer.azure_test ‑ test_getcwd
sarracenia.transfer.azure_test ‑ test_ls
sarracenia.transfer.azure_test ‑ test_mkdir
sarracenia.transfer.azure_test ‑ test_put
sarracenia.transfer.azure_test ‑ test_registered_as
sarracenia.transfer.azure_test ‑ test_rename
sarracenia.transfer.azure_test ‑ test_rmdir
sarracenia.transfer.azure_test ‑ test_umask
sarracenia.transfer.s3_test ‑ test___credentials
sarracenia.transfer.s3_test ‑ test___init__
sarracenia.transfer.s3_test ‑ test_cd
sarracenia.transfer.s3_test ‑ test_cd_forced
sarracenia.transfer.s3_test ‑ test_check_is_connected
sarracenia.transfer.s3_test ‑ test_chmod
sarracenia.transfer.s3_test ‑ test_close
sarracenia.transfer.s3_test ‑ test_connect
sarracenia.transfer.s3_test ‑ test_delete
sarracenia.transfer.s3_test ‑ test_get
sarracenia.transfer.s3_test ‑ test_getcwd
sarracenia.transfer.s3_test ‑ test_ls
sarracenia.transfer.s3_test ‑ test_mkdir
sarracenia.transfer.s3_test ‑ test_put
sarracenia.transfer.s3_test ‑ test_registered_as
sarracenia.transfer.s3_test ‑ test_rename
sarracenia.transfer.s3_test ‑ test_rmdir
sarracenia.transfer.s3_test ‑ test_umask