Closed abelanger5 closed 5 days ago
Minimal repro:
from hatchet_sdk import Hatchet, Context, ConcurrencyLimitStrategy from hatchet_sdk.rate_limit import RateLimit, RateLimitDuration from hatchet_sdk.workflows_pb2 import ConcurrencyLimitStrategy import time hatchet = Hatchet( ) @hatchet.workflow(name="third-python-workflow", version="1.6.5", timeout="150h", schedule_timeout="140h") class MyWorkflow: @hatchet.step(timeout="150h") #, rate_limits=[RateLimit("training", 1), RateLimit("global", 1)]) def stepOne(self, context: Context): context.log("BAM!") time.sleep(3) return { "result": "success" }
Minimal repro: