bump min locust-cloud version to latest

Author: cyberw

locust/argument_parser.py

@@ -773,12 +773,6 @@ def setup_parser_arguments(parser):
         action="store_true",
         help="Prints the final stats in JSON format to stdout. Useful for parsing the results in other programs/scripts. Use together with --headless and --skip-log for an output only with the json data.",
     )
-    stats_group.add_argument(
-        "--json-file",
-        metavar="<filename>",
-        dest="json_file",
-        help="Prints the final stats in JSON format to file path specified.",
-    )
 
     log_group = parser.add_argument_group("Logging options")
     log_group.add_argument(

locust/input_events.py

@@ -99,9 +99,8 @@ def input_listener(key_to_func_map: dict[str, Callable]):
     def input_listener_func():
         try:
             poller = get_poller()
-        except InitError:
-            # This is a bit chatty, even for debug. Uncomment it if you're having problems with keyboard events
-            # logging.debug(e)
+        except InitError as e:
+            logging.debug(e)
             return
 
         try:

locust/main.py

@@ -640,8 +640,6 @@ def shutdown():
             runner.quit()
         if options.json:
             stats.print_stats_json(runner.stats)
-        if options.json_file:
-            stats.save_stats_json(runner.stats, options.json_file)
         elif not isinstance(runner, locust.runners.WorkerRunner):
             stats.print_stats(runner.stats, current=False)
             stats.print_percentile_stats(runner.stats)

locust/stats.py

@@ -820,11 +820,6 @@ def print_stats_json(stats: RequestStats) -> None:
     print(json.dumps(stats.serialize_stats(), indent=4))
 
 
-def save_stats_json(stats: RequestStats, filename: str) -> None:
-    with open(f"{filename}.json", "w") as file:
-        json.dump(stats.serialize_stats(), file, indent=4)
-
-
 def get_stats_summary(stats: RequestStats, current=True) -> list[str]:
     """
     stats summary will be returned as list of string

locust/test/test_main.py

@@ -2067,54 +2067,6 @@ def hello_world(self):
             self.assertEqual(dict, type(result["num_reqs_per_sec"]))
             self.assertEqual(dict, type(result["num_fail_per_sec"]))
 
-    def test_json_file(self):
-        LOCUSTFILE_CONTENT = textwrap.dedent(
-            """
-            from locust import HttpUser, task, constant
-
-            class QuickstartUser(HttpUser):
-                wait_time = constant(1)
-
-                @task
-                def hello_world(self):
-                    self.client.get("/")
-
-            """
-        )
-        output_base = "locust_output"
-        output_filepath = f"{output_base}.json"
-        if os.path.exists(output_filepath):
-            os.remove(output_filepath)
-        with mock_locustfile(content=LOCUSTFILE_CONTENT) as mocked:
-            proc = subprocess.Popen(
-                [
-                    "locust",
-                    "-f",
-                    mocked.file_path,
-                    "--host",
-                    "http://google.com",
-                    "--headless",
-                    "-u",
-                    "1",
-                    "-t",
-                    "2s",
-                    "--json-file",
-                    output_base,
-                ],
-                stderr=PIPE,
-                stdout=PIPE,
-                text=True,
-            )
-            stdout, stderr = proc.communicate()
-            self.assertNotIn("error: argument --json-file: expected one argument", stderr)
-            self.assertTrue(os.path.exists(output_filepath))
-            with open(output_filepath, encoding="utf-8") as file:
-                [stats] = json.load(file)
-                self.assertEqual(stats["name"], "/")
-
-        if os.path.exists(output_filepath):
-            os.remove(output_filepath)
-
     @unittest.skipIf(True, reason="This test is too slow for the value it provides")
     def test_worker_indexes(self):
         content = """

locust/webui/src/components/SwarmForm/tests/SwarmForm.test.tsx

@@ -11,12 +11,6 @@ import { camelCaseKeys, queryStringToObject, toTitleCase } from 'utils/string';
 
 const startSwarm = vi.fn();
 
-const getStartSwarmMockCall = () => {
-  const mockCalls = startSwarm.mock.calls[0];
-
-  return mockCalls && mockCalls[0];
-};
-
 const server = setupServer(
   http.post(`${TEST_BASE_API}/swarm`, async ({ request }) =>
     startSwarm(camelCaseKeys(queryStringToObject(await request.text()))),
@@ -39,7 +33,7 @@ describe('SwarmForm', () => {
     });
 
     await waitFor(async () => {
-      const submittedData = getStartSwarmMockCall();
+      const submittedData = startSwarm.mock.calls[0][0];
 
       if (submittedData) {
         expect(submittedData).toEqual({
@@ -85,7 +79,7 @@ describe('SwarmForm', () => {
     });
 
     await waitFor(async () => {
-      const submittedData = getStartSwarmMockCall();
+      const submittedData = startSwarm.mock.calls[0][0];
 
       if (submittedData) {
         expect(submittedData).toEqual({
@@ -133,7 +127,7 @@ describe('SwarmForm', () => {
     });
 
     await waitFor(async () => {
-      const submittedData = getStartSwarmMockCall();
+      const submittedData = startSwarm.mock.calls[0][0];
 
       if (submittedData) {
         expect(submittedData).toEqual({
@@ -181,7 +175,7 @@ describe('SwarmForm', () => {
     });
 
     await waitFor(() => {
-      const submittedData = getStartSwarmMockCall();
+      const submittedData = startSwarm.mock.calls[0][0];
 
       if (submittedData) {
         expect(submittedData).toEqual({
@@ -239,7 +233,7 @@ describe('SwarmForm', () => {
     });
 
     await waitFor(async () => {
-      const submittedData = getStartSwarmMockCall();
+      const submittedData = startSwarm.mock.calls[0][0];
 
       if (submittedData) {
         expect(submittedData).toEqual({
@@ -268,7 +262,7 @@ describe('SwarmForm', () => {
     });
 
     await waitFor(async () => {
-      const submittedData = getStartSwarmMockCall();
+      const submittedData = startSwarm.mock.calls[0][0];
 
       if (submittedData) {
         expect(submittedData).toEqual({