Improve logging of copy methods (#599)

This commit extracts the log messages of the `BaseConnector` copy
methods into separate functions, which can be easily invoked from other
`Connector` classes. Tha aim is to uniform the logging messages for all
the StreamFLow `Connector` classes.

In addition, this commit fixes an issue with remote-to-remote copy
inside the `ContainerConnector` logic.

Author: GlassOfWhiskey

examples/flux/README.md

@@ -34,7 +34,7 @@ uses `mpirun`, but since Flux has MPI bindings, we replace this with flux run.
 You'll see the streamflow result printed to the screen:
 
 ```console
-2023-04-02 19:35:18.426 INFO     COMPLETED Workflow execution
+2023-04-02 19:35:18.426 INFO     COMPLETED workflow execution
 {
     "result": {
         "basename": "mpi_output.log",
@@ -49,7 +49,7 @@ You'll see the streamflow result printed to the screen:
     }
 }
 2023-04-02 19:35:18.428 INFO     UNDEPLOYING dc-mpi
-2023-04-02 19:35:18.443 INFO     COMPLETED Undeployment of dc-mpi
+2023-04-02 19:35:18.443 INFO     COMPLETED undeployment of dc-mpi
 ```
 
 And the output directory will be in your working directory:

streamflow/cwl/main.py

@@ -89,11 +89,11 @@ async def main(
         return
     await workflow.save(context)
     if logger.isEnabledFor(logging.INFO):
-        logger.info("COMPLETED Building of workflow execution plan")
+        logger.info("COMPLETED building of workflow execution plan")
     executor = StreamFlowExecutor(workflow)
     if logger.isEnabledFor(logging.INFO):
-        logger.info(f"Running workflow {args.name}")
+        logger.info(f"EXECUTING workflow {args.name}")
     output_tokens = await executor.run()
     if logger.isEnabledFor(logging.INFO):
-        logger.info("COMPLETED Workflow execution")
+        logger.info("COMPLETED workflow execution")
     print(json.dumps(output_tokens, sort_keys=True, indent=4))