diff --git a/tests/calculations/arithmetic/test_add.py b/tests/calculations/arithmetic/test_add.py
index 925467eb0e..f5c8c3af95 100644
--- a/tests/calculations/arithmetic/test_add.py
+++ b/tests/calculations/arithmetic/test_add.py
@@ -8,14 +8,11 @@
 ###########################################################################
 """Tests for the `ArithmeticAddCalculation` plugin."""
 
-import pytest
-
 from aiida import orm
 from aiida.calculations.arithmetic.add import ArithmeticAddCalculation
 from aiida.common import datastructures
 
 
-@pytest.mark.requires_rmq
 def test_add_default(fixture_sandbox, aiida_localhost, generate_calc_job):
     """Test a default `ArithmeticAddCalculation`."""
     inputs = {
@@ -46,7 +43,6 @@ def test_add_default(fixture_sandbox, aiida_localhost, generate_calc_job):
         assert input_written == f"echo $(({inputs['x'].value} + {inputs['y'].value}))\n"
 
 
-@pytest.mark.requires_rmq
 def test_add_custom_filenames(fixture_sandbox, aiida_localhost, generate_calc_job):
     """Test an `ArithmeticAddCalculation` with non-default input and output filenames."""
     input_filename = 'custom.in'
@@ -71,7 +67,6 @@ def test_add_custom_filenames(fixture_sandbox, aiida_localhost, generate_calc_jo
     assert calc_info.retrieve_list == [output_filename]
 
 
-@pytest.mark.requires_rmq
 def test_sleep(fixture_sandbox, aiida_localhost, generate_calc_job):
     """Test the ``metadata.options.sleep`` input."""
     sleep = 5
diff --git a/tests/calculations/test_stash.py b/tests/calculations/test_stash.py
index 364b0baf43..93e8d4dd98 100644
--- a/tests/calculations/test_stash.py
+++ b/tests/calculations/test_stash.py
@@ -23,7 +23,6 @@
 from aiida.plugins import CalculationFactory
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.parametrize(
     'operation_type,entry_point_name',
     [
@@ -215,7 +214,6 @@ def create_unstash_source_node():
             generate_calc_job(fixture_sandbox, 'core.unstash', unstash_input)
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.parametrize('unstash_target_mode', [UnstashTargetMode.NewRemoteData, UnstashTargetMode.OriginalPlace])
 def test_submit_custom_code(fixture_sandbox, aiida_localhost, generate_calc_job, tmp_path, unstash_target_mode):
     """Test the full functionality of the `StashCalculation` and `UnstashCalculation` with a custom code submission."""
@@ -369,7 +367,6 @@ def test_submit_custom_code(fixture_sandbox, aiida_localhost, generate_calc_job,
 
 
 @pytest.mark.usefixtures('aiida_profile_clean')
-@pytest.mark.requires_rmq
 @pytest.mark.parametrize(
     'unstash_target_mode', [UnstashTargetMode.OriginalPlace.value, UnstashTargetMode.NewRemoteData.value]
 )
diff --git a/tests/calculations/test_templatereplacer.py b/tests/calculations/test_templatereplacer.py
index cad048debc..ea55609b8c 100644
--- a/tests/calculations/test_templatereplacer.py
+++ b/tests/calculations/test_templatereplacer.py
@@ -10,13 +10,10 @@
 
 import io
 
-import pytest
-
 from aiida import orm
 from aiida.common import datastructures
 
 
-@pytest.mark.requires_rmq
 def test_base_template(fixture_sandbox, aiida_localhost, generate_calc_job):
     """Test a base template that emulates the arithmetic add."""
     entry_point_name = 'core.templatereplacer'
@@ -57,7 +54,6 @@ def test_base_template(fixture_sandbox, aiida_localhost, generate_calc_job):
         assert input_written == f"echo $(({inputs['parameters']['x']} + {inputs['parameters']['y']}))"
 
 
-@pytest.mark.requires_rmq
 def test_file_usage(fixture_sandbox, aiida_localhost, generate_calc_job):
     """Test a base template that uses two files."""
     file1_node = orm.SinglefileData(io.BytesIO(b'Content of file 1'))
diff --git a/tests/calculations/test_transfer.py b/tests/calculations/test_transfer.py
index 3fc43649b8..5d6a80f334 100644
--- a/tests/calculations/test_transfer.py
+++ b/tests/calculations/test_transfer.py
@@ -10,13 +10,10 @@
 
 import os
 
-import pytest
-
 from aiida import orm
 from aiida.common import datastructures
 
 
-@pytest.mark.requires_rmq
 def test_get_transfer(fixture_sandbox, aiida_localhost, generate_calc_job, tmp_path):
     """Test a default `TransferCalculation`."""
     file1 = tmp_path / 'file1.txt'
@@ -64,7 +61,6 @@ def test_get_transfer(fixture_sandbox, aiida_localhost, generate_calc_job, tmp_p
     assert sorted(calc_info.retrieve_list) == sorted(retrieve_list)
 
 
-@pytest.mark.requires_rmq
 def test_put_transfer(fixture_sandbox, aiida_localhost, generate_calc_job, tmp_path):
     """Test a default `TransferCalculation`."""
     file1 = tmp_path / 'file1.txt'
@@ -197,7 +193,6 @@ def test_validate_transfer_inputs(aiida_localhost, tmp_path):
     assert result == expected
 
 
-@pytest.mark.requires_rmq
 def test_integration_transfer(aiida_localhost, tmp_path):
     """Test a default `TransferCalculation`."""
     from aiida.calculations.transfer import TransferCalculation
diff --git a/tests/cmdline/commands/test_data.py b/tests/cmdline/commands/test_data.py
index 28f33c40a5..041f893241 100644
--- a/tests/cmdline/commands/test_data.py
+++ b/tests/cmdline/commands/test_data.py
@@ -233,7 +233,6 @@ def test_arrayshow(self):
         assert res.exit_code == 0, 'The command did not finish correctly'
 
 
-@pytest.mark.requires_rmq
 class TestVerdiDataBands(DummyVerdiDataListable):
     """Testing verdi data core.bands."""
 
diff --git a/tests/cmdline/commands/test_run.py b/tests/cmdline/commands/test_run.py
index 4ad0111d75..3ad3d69099 100644
--- a/tests/cmdline/commands/test_run.py
+++ b/tests/cmdline/commands/test_run.py
@@ -11,8 +11,6 @@
 import tempfile
 import textwrap
 
-import pytest
-
 from aiida.cmdline.commands import cmd_run
 from aiida.common.log import override_log_level
 
@@ -20,7 +18,6 @@
 class TestVerdiRun:
     """Tests for `verdi run`."""
 
-    @pytest.mark.requires_rmq
     def test_run_workfunction(self, run_cli_command):
         """Regression test for #2165
 
@@ -159,7 +156,6 @@ def test_no_autogroup(self, run_cli_command):
             all_auto_groups = queryb.all()
             assert len(all_auto_groups) == 0, 'There should be no autogroup generated'
 
-    @pytest.mark.requires_rmq
     def test_autogroup_filter_class(self, run_cli_command):
         """Check if the autogroup is properly generated but filtered classes are skipped."""
         from aiida.orm import AutoGroup, Node, QueryBuilder, load_node
diff --git a/tests/engine/processes/calcjobs/test_calc_job.py b/tests/engine/processes/calcjobs/test_calc_job.py
index f8c861c3a7..fda1b99e81 100644
--- a/tests/engine/processes/calcjobs/test_calc_job.py
+++ b/tests/engine/processes/calcjobs/test_calc_job.py
@@ -57,7 +57,6 @@ def _factory(**kwargs):
     return _factory
 
 
-@pytest.mark.requires_rmq
 class DummyCalcJob(CalcJob):
     """`DummyCalcJob` implementation to test the calcinfo with container code."""
 
@@ -81,7 +80,6 @@ def prepare_for_submission(self, folder):
         return calcinfo
 
 
-@pytest.mark.requires_rmq
 class FileCalcJob(CalcJob):
     """Example `CalcJob` implementation to test the `provenance_exclude_list` functionality.
 
@@ -119,7 +117,6 @@ def prepare_for_submission(self, folder):
         return calcinfo
 
 
-@pytest.mark.requires_rmq
 class MultiCodesCalcJob(CalcJob):
     """`MultiCodesCalcJob` implementation to test the calcinfo with multiple codes set.
 
@@ -250,7 +247,6 @@ def define(cls, spec):
     assert len(job_tmpl['codes_info'][0]['prepend_cmdline_params']) == expected
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.usefixtures('chdir_tmp_path')
 @pytest.mark.parametrize('parallel_run', [True, False])
 def test_multi_codes_run_parallel(aiida_code_installed, file_regression, parallel_run):
@@ -279,7 +275,6 @@ def test_multi_codes_run_parallel(aiida_code_installed, file_regression, paralle
     file_regression.check(content, extension='.sh')
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.usefixtures('chdir_tmp_path')
 @pytest.mark.parametrize('computer_use_double_quotes', [True, False])
 def test_computer_double_quotes(
@@ -311,7 +306,6 @@ def test_computer_double_quotes(
     file_regression.check(content, extension='.sh')
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.usefixtures('chdir_tmp_path')
 @pytest.mark.parametrize('code_use_double_quotes', [True, False])
 def test_code_double_quotes(aiida_localhost, file_regression, code_use_double_quotes):
@@ -338,7 +332,6 @@ def test_code_double_quotes(aiida_localhost, file_regression, code_use_double_qu
     file_regression.check(content, extension='.sh')
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.usefixtures('chdir_tmp_path')
 def test_containerized_code(file_regression, aiida_localhost):
     """Test the :class:`~aiida.orm.nodes.data.code.containerized.ContainerizedCode`."""
@@ -371,7 +364,6 @@ def test_containerized_code(file_regression, aiida_localhost):
     file_regression.check(content, extension='.sh')
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.usefixtures('chdir_tmp_path')
 def test_containerized_code_wrap_cmdline_params(file_regression, aiida_localhost):
     """Test :class:`~aiida.orm.nodes.data.code.containerized.ContainerizedCode` with ``wrap_cmdline_params = True``."""
@@ -405,7 +397,6 @@ def test_containerized_code_wrap_cmdline_params(file_regression, aiida_localhost
     file_regression.check(content, extension='.sh')
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.usefixtures('chdir_tmp_path')
 def test_containerized_code_withmpi_true(file_regression, aiida_localhost):
     """Test the :class:`~aiida.orm.nodes.data.code.containerized.ContainerizedCode` with ``withmpi=True``."""
@@ -438,7 +429,6 @@ def test_containerized_code_withmpi_true(file_regression, aiida_localhost):
     file_regression.check(content, extension='.sh')
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.usefixtures('chdir_tmp_path')
 def test_portable_code(tmp_path, aiida_localhost):
     """Test run container code"""
@@ -484,7 +474,6 @@ def test_portable_code(tmp_path, aiida_localhost):
     assert subsubcontent == 'sub dummy'
 
 
-@pytest.mark.requires_rmq
 class TestCalcJob:
     """Test for the `CalcJob` process sub class."""
 
@@ -855,7 +844,6 @@ def _generate_process(inputs=None):
     return _generate_process
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.usefixtures('override_logging')
 def test_parse_insufficient_data(generate_process):
     """Test the scheduler output parsing logic in `CalcJob.parse`.
@@ -886,7 +874,6 @@ def test_parse_insufficient_data(generate_process):
         assert log in logs
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.usefixtures('override_logging')
 def test_parse_non_zero_retval(generate_process):
     """Test the scheduler output parsing logic in `CalcJob.parse`.
@@ -906,7 +893,6 @@ def test_parse_non_zero_retval(generate_process):
     assert 'could not parse scheduler output: return value of `detailed_job_info` is non-zero' in logs
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.usefixtures('override_logging')
 def test_parse_not_implemented(generate_process):
     """Test the scheduler output parsing logic in `CalcJob.parse`.
@@ -938,7 +924,6 @@ def test_parse_not_implemented(generate_process):
         assert log in logs
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.usefixtures('override_logging')
 def test_parse_scheduler_excepted(generate_process, monkeypatch):
     """Test the scheduler output parsing logic in `CalcJob.parse`.
@@ -976,7 +961,6 @@ def raise_exception(*args, **kwargs):
         assert log in logs
 
 
-@pytest.mark.requires_rmq
 @pytest.mark.parametrize(
     ('exit_status_scheduler', 'exit_status_retrieved', 'final'),
     (
@@ -1046,7 +1030,6 @@ def parse_retrieved_output(_, __):
     assert result.status == final
 
 
-@pytest.mark.requires_rmq
 def test_additional_retrieve_list(generate_process, fixture_sandbox):
     """Test the ``additional_retrieve_list`` option."""
     process = generate_process()
@@ -1342,7 +1325,6 @@ def _parse_submit_output(self, *args):
     assert node.exit_status == 418
 
 
-@pytest.mark.requires_rmq
 def test_restart_after_daemon_reset(get_calcjob_builder, daemon_client, submit_and_await):
     """Test that a job can be restarted when it is launched and the daemon is restarted.
 
diff --git a/tests/engine/processes/workchains/test_restart.py b/tests/engine/processes/workchains/test_restart.py
index bf870292d7..28662e5e81 100644
--- a/tests/engine/processes/workchains/test_restart.py
+++ b/tests/engine/processes/workchains/test_restart.py
@@ -94,7 +94,6 @@ def test_get_process_handlers_by_priority(generate_work_chain, inputs, prioritie
     ]
 
 
-@pytest.mark.requires_rmq
 def test_excepted_process(generate_work_chain, generate_calculation_node):
     """Test that the workchain aborts if the sub process was excepted."""
     process = generate_work_chain(SomeWorkChain, {})
@@ -103,7 +102,6 @@ def test_excepted_process(generate_work_chain, generate_calculation_node):
     assert process.inspect_process() == engine.BaseRestartWorkChain.exit_codes.ERROR_SUB_PROCESS_EXCEPTED
 
 
-@pytest.mark.requires_rmq
 def test_killed_process(generate_work_chain, generate_calculation_node):
     """Test that the workchain aborts if the sub process was killed."""
     process = generate_work_chain(SomeWorkChain, {})
@@ -112,7 +110,6 @@ def test_killed_process(generate_work_chain, generate_calculation_node):
     assert process.inspect_process() == engine.BaseRestartWorkChain.exit_codes.ERROR_SUB_PROCESS_KILLED
 
 
-@pytest.mark.requires_rmq
 def test_unhandled_failure(generate_work_chain, generate_calculation_node):
     """Test the unhandled failure mechanism.
 
@@ -131,7 +128,6 @@ def test_unhandled_failure(generate_work_chain, generate_calculation_node):
     )
 
 
-@pytest.mark.requires_rmq
 def test_unhandled_reset_after_success(generate_work_chain, generate_calculation_node):
     """Test `ctx.unhandled_failure` is reset to `False` in `inspect_process` after a successful process."""
     process = generate_work_chain(SomeWorkChain, {})
@@ -145,7 +141,6 @@ def test_unhandled_reset_after_success(generate_work_chain, generate_calculation
     assert process.ctx.unhandled_failure is False
 
 
-@pytest.mark.requires_rmq
 def test_unhandled_reset_after_handled(generate_work_chain, generate_calculation_node):
     """Test `ctx.unhandled_failure` is reset to `False` in `inspect_process` after a handled failed process."""
     process = generate_work_chain(SomeWorkChain, {})
@@ -166,7 +161,6 @@ def test_unhandled_reset_after_handled(generate_work_chain, generate_calculation
     assert process.ctx.unhandled_failure is False
 
 
-@pytest.mark.requires_rmq
 def test_run_process(generate_work_chain, generate_calculation_node, monkeypatch):
     """Test the `run_process` method."""
 
@@ -234,14 +228,12 @@ def setup(self):
             self.ctx.inputs.parameters = self.ctx.inputs.parameters.get_dict()
 
 
-@pytest.mark.requires_rmq
 def test_results():
     results, node = engine.launch.run_get_node(CustomBaseRestartWorkChain)
     assert results['sub'].result.value == 1
     assert node.exit_status == 11
 
 
-@pytest.mark.requires_rmq
 def test_wrap_bare_dict_inputs():
     """Test that ``BaseRestartWorkChain._wrap_bare_dict_inputs`` method works properly.
 
diff --git a/tests/engine/processes/workchains/test_utils.py b/tests/engine/processes/workchains/test_utils.py
index 4397c50828..9aa3678fad 100644
--- a/tests/engine/processes/workchains/test_utils.py
+++ b/tests/engine/processes/workchains/test_utils.py
@@ -19,7 +19,6 @@
 ArithmeticAddCalculation = CalculationFactory('core.arithmetic.add')
 
 
-@pytest.mark.requires_rmq
 class TestRegisterProcessHandler:
     """Tests for the `process_handler` decorator."""
 
diff --git a/tests/engine/test_calcfunctions.py b/tests/engine/test_calcfunctions.py
index 98c53aefa4..7cb3859f18 100644
--- a/tests/engine/test_calcfunctions.py
+++ b/tests/engine/test_calcfunctions.py
@@ -37,7 +37,6 @@ def execution_counter_calcfunction(data):
     return Int(data.value + 1)
 
 
-@pytest.mark.requires_rmq
 class TestCalcFunction:
     """Tests for calcfunctions.
 
diff --git a/tests/engine/test_futures.py b/tests/engine/test_futures.py
index b8ba78aa8f..73a44fef71 100644
--- a/tests/engine/test_futures.py
+++ b/tests/engine/test_futures.py
@@ -17,12 +17,12 @@
 from tests.utils import processes as test_processes
 
 
-@pytest.mark.requires_rmq
 class TestWf:
     """Test process futures."""
 
     TIMEOUT = 5.0  # seconds
 
+    @pytest.mark.requires_rmq
     def test_calculation_future_broadcasts(self):
         """Test calculation future broadcasts."""
         manager = get_manager()
diff --git a/tests/engine/test_launch.py b/tests/engine/test_launch.py
index 6aba82cdcc..b5dd2f56f7 100644
--- a/tests/engine/test_launch.py
+++ b/tests/engine/test_launch.py
@@ -131,7 +131,6 @@ def test_await_processes(aiida_code_installed, caplog):
     assert 'out of 1 processes terminated.' in caplog.records[0].message
 
 
-@pytest.mark.requires_rmq
 class TestLaunchers:
     """Class to test process launchers."""
 
@@ -210,7 +209,6 @@ def test_submit_store_provenance_false(self):
             launch.submit(AddWorkChain, term_a=self.term_a, term_b=self.term_b, metadata={'store_provenance': False})
 
 
-@pytest.mark.requires_rmq
 class TestLaunchersDryRun:
     """Test the launchers when performing a dry-run."""
 
@@ -233,6 +231,7 @@ def init_profile(self, aiida_localhost):
         except Exception:
             pass
 
+    @pytest.mark.requires_rmq
     def test_launchers_dry_run(self):
         """All launchers should work with `dry_run=True`, even `submit` which forwards to `run`."""
         inputs = {
@@ -259,6 +258,7 @@ def test_launchers_dry_run(self):
         node = launch.submit(ArithmeticAddCalculation, **inputs)
         assert isinstance(node, orm.CalcJobNode)
 
+    @pytest.mark.requires_rmq
     def test_launchers_dry_run_no_provenance(self):
         """Test the launchers in `dry_run` mode with `store_provenance=False`."""
         inputs = {
diff --git a/tests/engine/test_persistence.py b/tests/engine/test_persistence.py
index 7ca9908376..eb978749a6 100644
--- a/tests/engine/test_persistence.py
+++ b/tests/engine/test_persistence.py
@@ -16,7 +16,6 @@
 from tests.utils.processes import DummyProcess
 
 
-@pytest.mark.requires_rmq
 class TestProcess:
     """Test the basic saving and loading of process states."""
 
@@ -39,7 +38,6 @@ def test_save_load(self):
         assert loaded_process.state == plumpy.ProcessState.FINISHED
 
 
-@pytest.mark.requires_rmq
 class TestAiiDAPersister:
     """Test AiiDAPersister."""
 
diff --git a/tests/engine/test_process.py b/tests/engine/test_process.py
index 1fce019442..f72fc5ed8c 100644
--- a/tests/engine/test_process.py
+++ b/tests/engine/test_process.py
@@ -36,7 +36,6 @@ def define(cls, spec):
         spec.input('some.name.space.a', valid_type=orm.Int)
 
 
-@pytest.mark.requires_rmq
 class TestProcessNamespace:
     """Test process namespace"""
 
@@ -94,7 +93,6 @@ def on_stop(self):
         assert self._thread_id is threading.current_thread().ident
 
 
-@pytest.mark.requires_rmq
 class TestProcess:
     """Test AiiDA process."""
 
diff --git a/tests/engine/test_run.py b/tests/engine/test_run.py
index fd4fd5ddfa..c7b08a5218 100644
--- a/tests/engine/test_run.py
+++ b/tests/engine/test_run.py
@@ -8,14 +8,11 @@
 ###########################################################################
 """Tests for the `run` functions."""
 
-import pytest
-
 from aiida.engine import run, run_get_node
 from aiida.orm import Int, ProcessNode, Str
 from tests.utils.processes import DummyProcess
 
 
-@pytest.mark.requires_rmq
 class TestRun:
     """Tests for the `run` functions."""
 
diff --git a/tests/engine/test_work_chain.py b/tests/engine/test_work_chain.py
index 4306d18591..453103bbf8 100644
--- a/tests/engine/test_work_chain.py
+++ b/tests/engine/test_work_chain.py
@@ -223,7 +223,6 @@ def success(self):
         self.out(self.OUTPUT_LABEL, Int(self.OUTPUT_VALUE).store())
 
 
-@pytest.mark.requires_rmq
 class TestExitStatus:
     """This class should test the various ways that one can exit from the outline flow of a WorkChain, other than
     it running it all the way through. Currently this can be done directly in the outline by calling the `return_`
@@ -303,7 +302,6 @@ def step2(self):
         self.ctx.s2 = True
 
 
-@pytest.mark.requires_rmq
 class TestContext:
     def test_attributes(self):
         wc = IfTest()
@@ -324,7 +322,6 @@ def test_dict(self):
             wc.ctx['new_attr']
 
 
-@pytest.mark.requires_rmq
 class TestWorkchain:
     @pytest.fixture(autouse=True)
     def init_profile(self):
@@ -1099,7 +1096,6 @@ def test_member_calcfunction_daemon(self, entry_points, daemon_client, submit_an
         assert node.outputs.out_static == 3
 
 
-@pytest.mark.requires_rmq
 class TestWorkChainAbort:
     """Test the functionality to abort a workchain"""
 
@@ -1170,7 +1166,6 @@ async def run_async():
         assert process.node.is_killed is True
 
 
-@pytest.mark.requires_rmq
 class TestWorkChainAbortChildren:
     """Test the functionality to abort a workchain and verify that children
     are also aborted appropriately
@@ -1225,6 +1220,7 @@ def test_simple_run(self):
         assert process.node.is_excepted is True
         assert process.node.is_killed is False
 
+    @pytest.mark.requires_rmq
     def test_simple_kill_through_process(self):
         """Run the workchain for one step and then kill it. This should have the
         workchain and its children end up in the KILLED state.
@@ -1255,7 +1251,6 @@ async def run_async():
         assert process.node.is_killed is True
 
 
-@pytest.mark.requires_rmq
 class TestImmutableInputWorkchain:
     """Test that inputs cannot be modified"""
 
@@ -1349,7 +1344,6 @@ def do_test(self):
         assert self.inputs.test == self.inputs.reference
 
 
-@pytest.mark.requires_rmq
 class TestSerializeWorkChain:
     """Test workchains with serialized input / output."""
 
@@ -1467,7 +1461,6 @@ def do_run(self):
         self.out('c', self.inputs.c)
 
 
-@pytest.mark.requires_rmq
 class TestWorkChainExpose:
     """Test the expose inputs / outputs functionality"""
 
@@ -1563,7 +1556,6 @@ def define(cls, spec):
         assert input_namespace['b'].help == 'An integer argument.'
 
 
-@pytest.mark.requires_rmq
 class TestWorkChainMisc:
     class PointlessWorkChain(WorkChain):
         @classmethod
@@ -1598,7 +1590,6 @@ def test_global_submit_raises(self):
             launch.run(TestWorkChainMisc.IllegalSubmitWorkChain)
 
 
-@pytest.mark.requires_rmq
 class TestDefaultUniqueness:
     """Test that default inputs of exposed nodes will get unique UUIDS."""
 
diff --git a/tests/engine/test_workfunctions.py b/tests/engine/test_workfunctions.py
index b84438ac6a..ae071c614c 100644
--- a/tests/engine/test_workfunctions.py
+++ b/tests/engine/test_workfunctions.py
@@ -16,7 +16,6 @@
 from aiida.orm import CalcFunctionNode, Int, WorkFunctionNode
 
 
-@pytest.mark.requires_rmq
 class TestWorkFunction:
     """Tests for workfunctions.
 
diff --git a/tests/orm/test_querybuilder.py b/tests/orm/test_querybuilder.py
index 8754d13d30..9f70cabd28 100644
--- a/tests/orm/test_querybuilder.py
+++ b/tests/orm/test_querybuilder.py
@@ -125,7 +125,6 @@ def test_get_group_type_filter(self):
 
     # Tracked in issue #4281
     @pytest.mark.flaky(reruns=2)
-    @pytest.mark.requires_rmq
     @pytest.mark.usefixtures('aiida_profile_clean')
     def test_process_query(self):
         """Test querying for a process class."""
diff --git a/tests/parsers/test_parser.py b/tests/parsers/test_parser.py
index e4b6af5be9..eaf64ed380 100644
--- a/tests/parsers/test_parser.py
+++ b/tests/parsers/test_parser.py
@@ -111,7 +111,6 @@ def test_parser_get_outputs_for_parsing(self):
         assert 'output' in outputs_for_parsing
         assert outputs_for_parsing['output'].uuid == output.uuid
 
-    @pytest.mark.requires_rmq
     def test_parse_from_node(self):
         """Test that the `parse_from_node` returns a tuple of the parsed output nodes and a calculation node.
 
@@ -144,7 +143,6 @@ def test_parse_from_node(self):
         # Verify that the `retrieved_temporary_folder` keyword can be passed, there is no validation though
         result, calcfunction = ArithmeticAddParser.parse_from_node(node, retrieved_temporary_folder='/some/path')
 
-    @pytest.mark.requires_rmq
     def test_parse_from_node_output_validation(self):
         """Test that the ``parse_from_node`` properly validates attached outputs.
 
diff --git a/tests/test_dataclasses.py b/tests/test_dataclasses.py
index df0a43c195..ab1dce91e4 100644
--- a/tests/test_dataclasses.py
+++ b/tests/test_dataclasses.py
@@ -205,7 +205,6 @@ def test_change_cifdata_file(self):
 
     @skip_ase
     @skip_pycifrw
-    @pytest.mark.requires_rmq
     @pytest.mark.filterwarnings('ignore:Cannot determine chemical composition from CIF:UserWarning:pymatgen.io')
     def test_get_structure(self):
         """Test `CifData.get_structure`."""
@@ -244,7 +243,6 @@ def test_get_structure(self):
 
     @skip_ase
     @skip_pycifrw
-    @pytest.mark.requires_rmq
     def test_ase_primitive_and_conventional_cells_ase(self):
         """Checking the number of atoms per primitive/conventional cell
         returned by ASE ase.io.read() method. Test input is
@@ -287,7 +285,6 @@ def test_ase_primitive_and_conventional_cells_ase(self):
     @skip_ase
     @skip_pycifrw
     @skip_pymatgen
-    @pytest.mark.requires_rmq
     @pytest.mark.filterwarnings('ignore:Cannot determine chemical composition from CIF:UserWarning:pymatgen.io')
     def test_ase_primitive_and_conventional_cells_pymatgen(self):
         """Checking the number of atoms per primitive/conventional cell
@@ -548,7 +545,6 @@ def test_attached_hydrogens(self):
     @skip_ase
     @skip_pycifrw
     @skip_spglib
-    @pytest.mark.requires_rmq
     def test_refine(self):
         """Test case for refinement (space group determination) for a
         CifData object.
@@ -1599,7 +1595,6 @@ def test_get_formula_unknown(self):
 
     @skip_ase
     @skip_pycifrw
-    @pytest.mark.requires_rmq
     def test_get_cif(self):
         """Tests the conversion to CifData"""
         import re
@@ -2878,7 +2873,6 @@ def test_creation(self):
             # Step 66 does not exist
             n.get_index_from_stepid(66)
 
-    @pytest.mark.requires_rmq
     def test_conversion_to_structure(self):
         """Check the methods to export a given time step to a StructureData node."""
         # Create a node with two arrays
diff --git a/tests/tools/archive/orm/test_calculations.py b/tests/tools/archive/orm/test_calculations.py
index 0f1c3bc63a..2a01da1d85 100644
--- a/tests/tools/archive/orm/test_calculations.py
+++ b/tests/tools/archive/orm/test_calculations.py
@@ -17,7 +17,6 @@
 from aiida.tools.archive import create_archive, import_archive
 
 
-@pytest.mark.requires_rmq
 def test_calcfunction(tmp_path, aiida_profile):
     """Test @calcfunction"""
     aiida_profile.reset_storage()
diff --git a/tests/workflows/arithmetic/test_add_multiply.py b/tests/workflows/arithmetic/test_add_multiply.py
index 1de06ff369..dd099ff381 100644
--- a/tests/workflows/arithmetic/test_add_multiply.py
+++ b/tests/workflows/arithmetic/test_add_multiply.py
@@ -8,8 +8,6 @@
 ###########################################################################
 """Tests for the `aiida.workflows.arithmetic.add_multiply` work function."""
 
-import pytest
-
 from aiida.orm import Int
 from aiida.plugins import WorkflowFactory
 from aiida.workflows.arithmetic.add_multiply import add_multiply
@@ -21,7 +19,6 @@ def test_factory():
     assert loaded.is_process_function
 
 
-@pytest.mark.requires_rmq
 def test_run():
     """Test running the work function."""
     x = Int(1)