fix: pass max runs and concurrency limit thru

Author: mrkaye97

hatchet_sdk/v2/workflows.py

@@ -116,6 +116,8 @@ def __init__(
         desired_worker_labels: dict[str, DesiredWorkerLabels] = {},
         backoff_factor: float | None = None,
         backoff_max_seconds: int | None = None,
+        concurrency__max_runs: int | None = None,
+        concurrency__limit_strategy: ConcurrencyLimitStrategy | None = None,
     ) -> None:
         self.fn = fn
         self.is_async_function = is_async_fn(fn)
@@ -129,8 +131,8 @@ def __init__(
         self.desired_worker_labels = desired_worker_labels
         self.backoff_factor = backoff_factor
         self.backoff_max_seconds = backoff_max_seconds
-        self.concurrency__max_runs = 1
-        self.concurrency__limit_strategy = ConcurrencyLimitStrategy.CANCEL_IN_PROGRESS
+        self.concurrency__max_runs = concurrency__max_runs
+        self.concurrency__limit_strategy = concurrency__limit_strategy
 
     def call(self, ctx: Context) -> R:
         if self.is_async_function: