Skip to content

Commit 9bbe988

Browse files
committed
some async changes
1 parent 0319803 commit 9bbe988

File tree

3 files changed

+5
-1
lines changed

3 files changed

+5
-1
lines changed

codeflash/api/aiservice.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -101,6 +101,7 @@ def optimize_python_code( # noqa: D417
101101
trace_id: str,
102102
num_candidates: int = 10,
103103
experiment_metadata: ExperimentMetadata | None = None,
104+
is_async: bool = False,
104105
) -> list[OptimizedCandidate]:
105106
"""Optimize the given python code for performance by making a request to the Django endpoint.
106107
@@ -131,6 +132,7 @@ def optimize_python_code( # noqa: D417
131132
"current_username": get_last_commit_author_if_pr_exists(None),
132133
"repo_owner": git_repo_owner,
133134
"repo_name": git_repo_name,
135+
"is_async": is_async,
134136
}
135137

136138
logger.info("Generating optimized candidates…")

codeflash/code_utils/edit_generated_tests.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -201,7 +201,7 @@ def remove_functions_from_generated_tests(
201201
for generated_test in generated_tests.generated_tests:
202202
for test_function in test_functions_to_remove:
203203
function_pattern = re.compile(
204-
rf"(@pytest\.mark\.parametrize\(.*?\)\s*)?def\s+{re.escape(test_function)}\(.*?\):.*?(?=\ndef\s|$)",
204+
rf"(@pytest\.mark\.parametrize\(.*?\)\s*)?(async\s+)?def\s+{re.escape(test_function)}\(.*?\):.*?(?=\n(async\s+)?def\s|$)",
205205
re.DOTALL,
206206
)
207207

codeflash/optimization/function_optimizer.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -983,6 +983,7 @@ def generate_tests_and_optimizations(
983983
self.function_trace_id[:-4] + "EXP0" if run_experiment else self.function_trace_id,
984984
N_CANDIDATES,
985985
ExperimentMetadata(id=self.experiment_id, group="control") if run_experiment else None,
986+
self.function_to_optimize.is_async,
986987
)
987988
future_candidates_exp = None
988989

@@ -998,6 +999,7 @@ def generate_tests_and_optimizations(
998999
self.function_trace_id[:-4] + "EXP1",
9991000
N_CANDIDATES,
10001001
ExperimentMetadata(id=self.experiment_id, group="experiment"),
1002+
self.function_to_optimize.is_async,
10011003
)
10021004
futures.append(future_candidates_exp)
10031005

0 commit comments

Comments
 (0)