| 1771 | } |
| 1772 | |
| 1773 | static OnFailedPolicy getOnFailedPolicy(const char* onFailurePolicyStr){ |
| 1774 | if(strcasecmp(onFailurePolicyStr, "Continue") == 0){ |
| 1775 | return OnFailedPolicyContinue; |
| 1776 | } |
| 1777 | if(strcasecmp(onFailurePolicyStr, "Abort") == 0){ |
| 1778 | return OnFailedPolicyAbort; |
| 1779 | } |
| 1780 | if(strcasecmp(onFailurePolicyStr, "Retry") == 0){ |
| 1781 | return OnFailedPolicyRetry; |
| 1782 | } |
| 1783 | return OnFailedPolicyUnknown; |
| 1784 | } |
| 1785 | |
| 1786 | static void* registerCreateStreamArgs(PyObject *kargs, const char* prefix, ExecutionMode mode){ |
| 1787 | size_t batch = 1; |
no outgoing calls
no test coverage detected