') + ')', 'gi'); if (regex.test(text)) { found = true; var frag = document.createDocumentFragment(); var parts = text.split(regex); parts.forEach(function(part, i) { if (i % 2 === 0) { frag.appendChild(document.createTextNode(part)); } else { var span = document.createElement('span'); span.className = 'userscript-highlight'; span.textContent = part; frag.appendChild(span); } }); node.parentNode.replaceChild(frag, node); } }); } else if (node.nodeType === 1 && node.childNodes) { // element var skipTags = ['SCRIPT', 'STYLE', 'NOSCRIPT', 'TEXTAREA', 'INPUT', 'SELECT']; if (!skipTags.includes(node.tagName)) { Array.from(node.childNodes).forEach(highlight); } } } highlight(document.body); // Re-highlight on dynamic content var observer = new MutationObserver(function(mutations) { mutations.forEach(function(m) { m.addedNodes.forEach(function(node) { if (node.nodeType === 1 || node.nodeType === 3) highlight(node); }); }); }); observer.observe(document.body, { childList: true, subtree: true }); })(); } } catch(__e) { console.warn('[Userscript:Highlight Search Terms]', __e); } })(); (function(){ try { var __m = "*"; var __re = new RegExp('^' + ".*" + ', 'i'); if (__m === '*' || __re.test(location.href)) { // Strip utm_, fbclid, gclid, etc. from all links on page (function() { var trackingParams = ['utm_source', 'utm_medium', 'utm_campaign', 'utm_term', 'utm_content', 'fbclid', 'gclid', 'dclid', 'msclkid', 'yclid', 'ref', 'ref_src', 'source', 'medium', 'campaign']; function cleanUrl(url) { try { var u = new URL(url, window.location.origin); var changed = false; trackingParams.forEach(function(p) { if (u.searchParams.has(p)) { u.searchParams.delete(p); changed = true; } }); return changed ? u.toString() : url; } catch (e) { return url; } } function cleanLinks() { document.querySelectorAll('a[href]').forEach(function(a) { var clean = cleanUrl(a.href); if (clean !== a.href) a.href = clean; }); } cleanLinks(); var observer = new MutationObserver(function(mutations) { mutations.forEach(function(m) { m.addedNodes.forEach(function(node) { if (node.nodeType === 1) { if (node.tagName === 'A') cleanLinks(); node.querySelectorAll('a[href]').forEach(function(a) { var clean = cleanUrl(a.href); if (clean !== a.href) a.href = clean; }); } }); }); }); observer.observe(document.body, { childList: true, subtree: true }); })(); } } catch(__e) { console.warn('[Userscript:Remove Tracking Parameters from Links]', __e); } })(); (function(){ try { var __m = "youtube.com"; var __re = new RegExp('^' + "youtube\\.com" + ', 'i'); if (__m === '*' || __re.test(location.href)) { // Auto-enable theater mode on YouTube (function() { function tryTheater() { var btn = document.querySelector('button[aria-label="Theater mode"], ytd-player #player button[title="Theater mode"]'); if (btn && !btn.classList.contains('activated')) { btn.click(); } } // Try immediately tryTheater(); // Try after navigation (SPA) var lastUrl = location.href; setInterval(function() { if (location.href !== lastUrl) { lastUrl = location.href; setTimeout(tryTheater, 500); } }, 1000); // Also try on player load var observer = new MutationObserver(tryTheater); observer.observe(document.body, { childList: true, subtree: true }); })(); } } catch(__e) { console.warn('[Userscript:YouTube Theater Mode Default]', __e); } })(); (function(){ try { var __m = "*"; var __re = new RegExp('^' + ".*" + ', 'i'); if (__m === '*' || __re.test(location.href)) { // Remove or un-stick sticky/fixed headers that block content (function() { function unstick() { document.querySelectorAll('header, nav, [role="banner"], .header, .navbar, .sticky, .fixed-top, [style*="position: fixed"], [style*="position:sticky"]').forEach(function(el) { if (el.style.position === 'fixed' || el.style.position === 'sticky' || getComputedStyle(el).position === 'fixed' || getComputedStyle(el).position === 'sticky') { el.style.position = 'static'; el.style.top = 'auto'; el.style.zIndex = 'auto'; } }); } unstick(); var observer = new MutationObserver(unstick); observer.observe(document.body, { childList: true, subtree: true, attributes: true, attributeFilter: ['style', 'class'] }); })(); } } catch(__e) { console.warn('[Userscript:Kill Sticky Headers]', __e); } })(); })(); feat: support coroutine functions as invoke targets by fgmacedo · Pull Request #611 · fgmacedo/python-statemachine · GitHub
Skip to content

feat: support coroutine functions as invoke targets - #611

Merged
fgmacedo merged 1 commit into
developfrom
feat/async-invoke-support
Apr 9, 2026
Merged

feat: support coroutine functions as invoke targets#611
fgmacedo merged 1 commit into
developfrom
feat/async-invoke-support

Conversation

@fgmacedo

@fgmacedofgmacedo commented Apr 9, 2026

Copy link
Copy Markdown
Owner

Summary

Closes#610.

  • Coroutine functions passed as invoke targets were silently broken: the coroutine was never awaited and the coroutine object was passed as data in the done.invoke event
  • The async engine now detects coroutine callbacks (callback._iscoro) and IInvoke handlers with async def run() (_has_async_run()) and awaits them directly on the event loop instead of routing through run_in_executor
  • InvalidDefinition is raised when async IInvoke handlers are used with the sync engine (raw coroutine functions already auto-select the async engine via the callback detection pipeline)
  • Ignores local specs/ directory in .gitignore

@fgmacedo
feat: support coroutine functions as invoke targets (#610)
8c24a42
Coroutine functions passed as invoke targets were silently broken: the
coroutine was never awaited and the coroutine object was passed as data
in the done.invoke event. Now the async engine detects coroutine
callbacks and IInvoke handlers with async run() and awaits them directly
on the event loop instead of routing through run_in_executor.
Also adds InvalidDefinition when async IInvoke handlers are used with
the sync engine, and ignores the local specs/ directory.
Signed-off-by: Fernando Macedo <fgmacedo@gmail.com>
@sonarqubecloud

sonarqubecloudBot commented Apr 9, 2026

Copy link
Copy Markdown

Quality Gate PassedQuality Gate passed

Issues
5 New issues
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud

@codecov

codecovBot commented Apr 9, 2026•
edited
Loading

Copy link
Copy Markdown

Codecov Report

✅ All modified and coverable lines are covered by tests.
✅ Project coverage is 100.00%. Comparing base (b7a46e5) to head (8c24a42).
⚠️ Report is 39 commits behind head on develop.

Additional details and impacted files
@@ Coverage Diff @@## develop #611 +/- ##
=========================================
Coverage 100.00% 100.00% =========================================
Files 42 42 Lines 5027 5027 Branches 812 812 =========================================
Hits 5027 5027
FlagCoverage Δ
unittests100.00% <ø> (ø)

Flags with carried forward coverage won't be shown. Click here to find out more.

☔ View full report in Codecov by Harness.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

@fgmacedofgmacedo added the bug label Apr 9, 2026
@fgmacedofgmacedo added this to the 3.1.0 milestone Apr 9, 2026
@fgmacedo
fgmacedo merged commit f54d9f5 into developApr 9, 2026
14 checks passed
@fgmacedo
fgmacedo deleted the feat/async-invoke-support branch April 9, 2026 23:21
@fgmacedofgmacedo mentioned this pull request Apr 10, 2026
Merged
@fgmacedofgmacedo mentioned this pull request Apr 18, 2026
Open
Sign up for freeto join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

No reviews

Assignees

No one assigned

Labels

bug

Projects

None yet

Milestone

3.1.0

Development

Successfully merging this pull request may close these issues.

Does Invoke always run in a thread?

1 participant

@fgmacedo