def test_add_port_fwd(self):
        with patch.object(firewalld, '__firewall_cmd', return_value='success'):
            self.assertEqual(firewalld.add_port_fwd('zone', '22', '2222', 'tcp'), 'success')
Function to perform Hadoop MapReduce task asynchronously.
dataset/ETHPy150Open saltstack/salt/tests/unit/modules/firewalld_test.py/FirewalldTestCase.test_add_port_fwd--crossover with--dataset/ETHPy150Open GoogleCloudPlatform/Data-Pipeline/app/static/hadoop_scripts/rpc_daemon/__main__.py/AsyncPerformMapReduce